DataWorks:for-eachノードのロジック

使用上の注意

シナリオ

DataWorksのfor-eachノードは、ループトラバーサルシナリオで使用され、割り当てノードと一緒に使用する必要があります。割り当てノードは、for-eachノードの祖先ノードとして設定する必要があります。割り当てノードがその出力をfor-eachノードに渡した後、for-eachノードは出力をループ処理します。

制限

• DataWorks Standard Edition以上のエディションのみがfor-eachノードをサポートしています。 DataWorksエディションの違いについては、DataWorksエディションの違いを参照してください。

• for-eachノードの最大ループ数は 1024 です。 for-eachノードの実際のループ数は、割り当てノードによって渡される結果セットによって決まります。

• 並列実行はサポートされていません。前のループが終了した場合にのみ、ループを開始できます。

注意事項

for-eachノードの構成とワークフローオーケストレーション

ループ数

組み込み変数

for-eachノードによって提供される組み込み変数を使用して、for-eachノードの祖先ノードとして設定されている割り当てノードによって渡された結果セットを取得できます。 for-eachノードの内部ワークフローに割り当てノードが含まれている場合は、デフォルトの方法を使用して割り当てノードの出力を取得できます。デフォルトの方法の詳細については、割り当てノードの設定を参照してください。

data=[] // データ＝[]

for(int i=0;i<data.length;i++) { // for（int i＝0; i＜data.length; i++）{
   print(data[i]); // print（data[i]）;
} // }

変数値の例

例 1：Shellノードが割り当てノードとして使用される

• 割り当てノードの出力

  Shellノードが割り当てノードとして使用され、割り当てノードの最後の出力は2021-03-28,2021-03-29,2021-03-30,2021-03-31,2021-04-01です。

• for-eachノードの変数の値

  説明

  割り当てノードの出力は1次元配列であり、配列内の5つの要素はコンマ (,) で区切られます。したがって、for-eachノードのループ数は 5 です。

  ${dag.loopDataArray}${dag.foreach.current[3]} // ${dag.loopDataArray[0][3]} の誤りではないか？

  組み込み変数	最初のループの値	2番目のループの値
  ${dag.loopDataArray}	2021-03-28,2021-03-29,2021-03-30,2021-03-31,2021-04-01
  ${dag.foreach.current}	2021-03-28	2021-03-29
  ${dag.offset}	0	1
  ${dag.loopTimes}	1	2
  ${dag.foreach.current[3]}	// 存在しないのでエラーとなる。

例 2：ODPS SQLノードが割り当てノードとして使用される

• 割り当てノードの出力

  ODPS SQLノードが割り当てノードとして使用され、最後のSELECTステートメントは次の2つのデータを返します。

  +----------------------------------------------+
  | uid            | region | age_range | zodiac |
  +----------------------------------------------+
  | 0016359810821  | Hubei Province | 30 to 40 years old   | Cancer | // 湖北省、30～40歳、かに座
  | 0016359814159  | Unknown   | 30 to 40 years old   | Cancer | // 不明、30～40歳、かに座
  +----------------------------------------------+

• for-eachノードの変数の値

  説明

  割り当てノードの出力は2次元配列であり、配列には2行のデータが含まれています。したがって、for-eachノードのループ数は 2 です。

  ${dag.loopDataArray[1][0]}

  組み込み変数	最初のループの値	2番目のループの値
  ${dag.loopDataArray}	+----------------------------------------------+ | uid | region | age_range | zodiac | +----------------------------------------------+ | 0016359810821 | Hubei Province | 30 to 40 years old | Cancer | //湖北省 | 0016359814159 | Unknown | 30 to 40 years old | Cancer | //不明 +----------------------------------------------+
  ${dag.foreach.current}	0016359810821,Hubei Province,30–40 years old,Cancer	0016359814159,unknown,30–40 years old,Cancer
  ${dag.offset}	0	1
  ${dag.loopTimes}	1	2
  ${dag.foreach.current[0]}	0016359810821	0016359814159
  ${dag.loopDataArray[1][0]}	0016359814159