subWorkflow
Definition
๋ค๋ฅธ ์ํฌํ๋ก์ฐ๋ฅผ ํ๋์ Node๋ก ์คํ ํ ์ ์๋ค. [Flow๊ตฌ์ฑ]๋ ธ๋ ์ค [subWorkflow]๋ ธ๋๋ฅผ drag & drop ํ ํ Property ํญ๋ชฉ์ ์ ๋ ฅํ๋ค. Property ํจ๋์ [๋๋ณด๊ธฐ+] ๋ฒํผ์ ๋๋ฅด๋ฉด ์ ๋ ฅ๊ฐ๋ฅํ ์ ์ฒด Property ํญ๋ชฉ์ ๋ณผ ์ ์๋ค.
๋ชฉ๋ก ์ด๊ธฐ๋ฅผ ๋๋ฅด๋ฉด ๋ชฉ๋ก์ด ํ์ ๋๊ณ ์ด์ค ํ๋๋ฅผ ์ ํํ๋ฉด ์ํฌํ๋ก์ฐ ๋ฒํธ๊ฐ ์ ๋ ฅ ๋๋ค.
Set
[setting], [scheduler], [parameter] ์ค์ ์ [์ํฌํ๋ก์ฐ ์์ฑ] > [์ค์ ]์ ์ฐธ๊ณ ํ๋ค.
property
[Node Description] ์์ฑ ์ค์ธ ๋ ธ๋๋ช ์ ๋ ฅ
- propagateConfiguration : subWorkflow ์ค์ ์ ๋ฌ ์ฌ๋ถ ์ ํ
- appPath : subworkflow ๋ชฉ๋ก์ฐฝ์์ ๋์ ์ํฌํ๋ก์ฐ ์ ํ. ์ ํํ๋ฉด workflowId, workflowName์ ์๋ ์ค์ ๋จ
- workflowId : ์ํฌํ๋ก์ฐ ID
- workflowName : ์ํฌํ๋ก์ฐ ์ด๋ฆ
- configuration : key-value๋ก ์ค์
- forceOK : ๋ฐ์ดํฐ ์ฒ๋ฆฌ๊ฐ ์คํจํด๋ ์ ์์ผ๋ก ํ์ํ๊ณ ์ข ๋ฃ
Example
executeHive(create table as select ์ฟผ๋ฆฌ ์คํ)๋ ธ๋๊ฐ ์คํ๋๋ ์ํฌํ๋ก์ฐ(G1378)๋ฅผ subWorkflow๋ก ์ค์ ํ ์คํ ๋ฐ ๊ฒฐ๊ณผ๊น์ง ํ์ธํ๋ค.
- executeHive workflow ์์ฑ
create table air_pollution_subworkflow_test
as select * from air_pollution limit 10
- [subWorkflow]๋ ธ๋๋ฅผ drag & drop ํ ํ Property ํญ๋ชฉ์ ์ ๋ ฅํ๋ค. 1๋ฒ์์ ์์ฑํ ์ํฌํ๋ก์ฐ๋ฅผ ์ฐพ์ ๋ฑ๋กํ๋ค.
- subworkflow ์คํ๊ฒฐ๊ณผ executeHive๋ ธ๋์ ์ค์ ํ ์ฟผ๋ฆฌ๊ฐ ์ ์ ์คํ๋์๋ค.