全体の目的
Talendの超簡単なサンプルジョブを作成して，ETLジョブ開発に必要なスキルを習得することが目的です。
対象者
ETL / EAI技術者
環境
| 使用環境 | バージョン |
|---|---|
| OS | Windows10 |
| Talend | 7.3.1 |
サンプル一覧
以下の順番で習得していきます
| # | 内容 |
|---|---|
| 1 | はじめてのTalend |
| 2 | ファイルI/O |
| 3 | データベースI/O |
| 4 | tMap |
| 5 | イテレータ |
| 6 | メタデータ |
| 7 | Context変数 |
| 8 | Global Map |
| 9 | tHashInput/tHashOutput |
| 10 | エラーハンドリング |
| 11 | ロギング |
| 12 | 子ジョブ（ジョブのネスト）（今回） |
| 13-1 | 設定ファイル読み込みオリジナル版 |
| 13-2 | 設定ファイル読み込みコンポ版 |
| 14 | tJava |
今回の目的
別々に作成したジョブにコンテキストの値や実行結果を渡す方法を理解する。
子ジョブと親ジョブについて
Talendでは[tRunJob]コンポーネントを用いてジョブを実行することができます。このとき[tRunJob]コンポーネントを用いてジョブを呼び出した側を親ジョブ、呼び出された側を子ジョブといいます。
また、プログラミング用語としてif（ 条件A ）{ ... if（ 条件B ）{ ... } ... } といったように、条件分岐やループの内部に、別の条件分岐やループなどが含まれている状態をネストまたは入れ子と呼びます。今回作成するジョブからジョブを呼び出す形もネストといえるでしょう。
参照：IT用語辞典 e-words
サンプルプログラム概要
- 子ジョブと親ジョブの二つのジョブを作成
- 親ジョブから子ジョブに値を渡す
- 親ジョブか渡された値を用いて子ジョブを実行する
- 子ジョブの実行結果を親ジョブに渡す
- 子ジョブから渡された値を用いて親ジョブの処理を実行する
子ジョブの作成
リポジトリの[ジョブ]を右クリックし[ジョブの作成]を選択します。
[名前]にchildと入力し[Finish]ボタンをクリックします。
[Contexts(context)]タブを開き[+]ボタンを１回クリックします。
そして、以下ようにContext変数を定義します。
| Name | Type | value |
|---|---|---|
| num_chiled | int integer | 0 |
[tJava]を配置します。
[tJava]のコードを以下のように記載します。
System.out.println("子ジョブでの初期値 : "+context.num_child);
context.num_child+=10;
System.out.println("子ジョブでの値を加算後 : "+context.num_child);
実行してみましょう。
初期値に１０が加算されていることが分かります。
親ジョブの作成
リポジトリの[ジョブ]を右クリックし[ジョブの作成]を選択します。
[名前]にparentと入力し[Finish]ボタンをクリックします。
リポジトリの[chiled]をドラッグ＆ドロップします。
[chiled]の[コンポーネント]タグを開いて[コンテキストパラメーター]の[+]ボタンを１回クリックします。
値は以下のように設定します。
| パラメータ | 値 |
|---|---|
| num_chiled | 2 |
実行してみましょう。
子ジョブのnum_chiledに２が渡されて子ジョブが実行されていることが分かります。
このままだと子ジョブの実行結果を親ジョブで使用できません。以降で子ジョブから親ジョブに値を渡す方法を説明します。
子ジョブの実行結果を親ジョブに渡す
子ジョブ
ジョブ[child]を開いて[tFixedFlowInput]、[tBufferOutput]を配置します。
[tJava_1]と[tFixedFlowInput_1]をOnSubjobOk、[tFixedFlowInput_1]と[tBufferOutput_1]をロウでつなぎます。
[tFixedFlowInput_1]のスキーマ編集画面で+を１回クリックし１カラム定義します。
[値]にoutChildが追加されるのでoutChildの値をcontext.num_childにします。
[tBufferOutput_1]の同期カラムをクリックします。
親ジョブ
ジョブ[parent]を開いて[tJavaRow]を配置します。
コンポーネント[child]と[tJavaRow_1]をロウでつなぎます。
コンポーネント[child]の[子ジョブのスキーマのコピー]をクリックします。
スキーマの編集画面を開くとoutChildが追加されています。
[tJavaRow_1]の[同期カラム]をクリックして、以下の文を[コード]に記述します。
System.out.println("子ジョブから親ジョブに値を渡したときの結果:"+row1.outChild);
row1.outChild += 100;
System.out.println("子ジョブから親ジョブに値を渡したあと100を加算した結果:"+row1.outChild);
実行してみましょう。
以下の４点が動作していることが確認できると思います。
- 親ジョブから子ジョブに値を渡す
- 親ジョブから渡された値を用いて子ジョブを実行する
- 子ジョブの実行結果を親ジョブに渡す
- 子ジョブから渡された値を用いて親ジョブの処理を実行する
まとめ
今回は子ジョブについて学んできました。
子ジョブを使うことで別々に作成したジョブに値を渡したり、受け取ることができました。
あらたに利用したコンポーネントと用途をおさらいしておきます。
- tRunJob
- コンポーネント[child]のことである。別のジョブを使いたいときに使用する。このとき、[tRunJob]を用いてジョブを呼び出すほうを親ジョブ、呼び出されるジョブを子ジョブという。
- tBufferOutput
- 子ジョブから親ジョブに値を返却するときに使用できる。
毎度のことですが、ほんのさわりの部分だけを解説していますのでぜひここから深掘りしてみてください。
次回以降
次回は設定ファイル読み込みについてやっていきます。