decision

Definition

decision 노드에 입력하는 조건에 따라 N개의 Node로 작업 flow를 분기 할 수 있습니다. 선행 노드의 결과에 따라 실행될 후행 노드가 다를 경우 사용합니다.
좌측 [Flow구성]노드 중 [decision]노드를 drag & drop 한 후 Property 항목을 입력합니다.

Set

[setting], [scheduler], [parameter] 설정은 [워크플로우] > [생성] > [기본구성]을 참고합니다.

property

[Node Description] 작성 중인 노드명 입력

1. switch : 조건문과 이동할 action 입력
   • case : 조건 입력
   • to : 조건에 따라 수행할 후속 노드 선택(콤보박스)
2. default : 기본으로 이동할 action
   • to : 노드 선택

Example

HDFS에 특정 파일 저장여부를 체크하여 파일이 있을 경우 "fileexist_yes", 없을 경우 "no_files"라는 0byte 파일을 생성합니다. ETL 수행결과가 정상적으로 생성되었는지 확인하는 검증로직 등으로 응용할 수 있습니다.

1. kbtest 클러스터에 검사대상 파일을 적재 (/tmp/test-ods/AIR_HOUR_2019_2.csv)
2. [decision] 및 [fs] 노드를 생성
3. [decision] 노드를 아래와 같이 설정
   • 경로에 파일이 있을 경우 [fs_fileexist]로 이동
     • case : ${fs:exists(("/tmp/test-ods/AIR_HOUR_2019_2.csv")) == "true"}
     • to : fs_fileexist
   • 경로에 파일이 없을 경우 [fs_nofiles]로 이동
     • case : ${fs:exists(("/tmp/test-ods/AIR_HOUR_2019_2.csv")) == "false"}
     • to : fs_nofiles

[Note] : oozie el function
case 입력 구문은 oozie el function 으로 세부 사항은 아래 사이트 참고 https://oozie.apache.org/docs/4.3.0/WorkflowFunctionalSpec.html#a4.2.2_Basic_EL_Functions

4. [fs]노드(fs_fileexist, fs_nofiles)를 아래와 같이 설정

   • fs_fileexist : property "5.touchz" > HDFS File Browser에서 "hdfs://kbtest-accu-hdfs-nn.suka:9000/tmp/test-ods"경로 설정 후 "/fileexist.yes" 입력
   • fs_nofiles : property "5.touchz" > HDFS File Browser에서 "hdfs://kbtest-accu-hdfs-nn.suka:9000/tmp/test-ods"경로 설정 후 "/no_files" 입력

5. 실행결과

   • 데이터가 있을 경우 지정한 경로에 fileexist.yes 생성 확인
   • 데이터가 없을 경우 지정한 경로에 no_files 생성 확인