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