左ルックアップ結合

対応している: Streaming

左側と右側のデータセットの入力を結合します 変換カテゴリ：結合

宣言された引数

• 左側で選択する列の条件 - 左側の入力スキーマのすべての行がこの条件に一致するかどうかをテストされます。一致する場合、出力でその行が選択されます。
  ColumnPredicate
• 右側で選択する列の条件 - 右側の入力スキーマのすべての行がこの条件に一致するかどうかをテストされます。一致する場合、出力でその行が選択されます。
  ColumnPredicate
• 結合条件 - 左側と右側の入力から結合するための行のリスト。
  List<Tuple<Column<Boolean | Byte | Date | Double | Float | Integer | Long | Short | String | Timestamp>, Column<Boolean | Byte | Date | Double | Float | Integer | Long | Short | String | Timestamp>>>
• 左側のデータセット - 結合で使用する左側のデータセット
  Table
• 右側のデータセット - 結合で使用する右側のデータセット
  Table
• オプション 右側からの列の接頭辞 - 右側のすべての行に追加する接頭辞。
  Literal<String>

例

例 1 - 基本ケース

引数の値:

• 左側で選択する列の条件:
  columnNameIsIn(
   columnNames: [tail_number, airline],
  )
• 右側で選択する列の条件:
  columnNameIsIn(
   columnNames: [home_airport],
  )
• 結合条件: [(tail_number, tail_number)]
• 左側のデータセット: ri.foundry.main.dataset.left
• 右側のデータセット: ri.foundry.main.dataset.right
• 右側からの列の接頭辞: null 入力: ri.foundry.main.dataset.leftri.foundry.main.dataset.right出力: | tail_number | airline | home_airport | | ----- | ----- | ----- | | XB-123 | foundry air | LHR | | MT-222 | new airline | CPH | | XB-123 | foundry airline | LHR | | MT-222 | new air | CPH | | KK-452 | new air | JFK | | PA-452 | new air | null | | XB-123 | foundry airline | LHR |

---

例 2 - 基本ケース

引数の値:

• 左側で選択する列の条件:
  columnNameIsIn(
   columnNames: [tail_number, airline, factor],
  )
• 右側で選択する列の条件:
  columnNameIsIn(
   columnNames: [home_airport],
  )
• 結合条件: [(tail_number, tail_number), (factor, factor)]
• 左側のデータセット: ri.foundry.main.dataset.left
• 右側のデータセット: ri.foundry.main.dataset.right
• 右側からの列の接頭辞: null 入力: ri.foundry.main.dataset.leftri.foundry.main.dataset.right出力: | tail_number | airline | factor | home_airport | | ----- | ----- | ----- | ----- | | XB-123 | foundry air | 2 | LHR | | MT-222 | new airline | 5 | null | | XB-123 | foundry airline | 5 | null | | MT-222 | new air | 4 | null | | KK-452 | new air | 1 | null | | PA-452 | new air | 2 | null | | XB-123 | foundry airline | 2 | LHR |

---

例 3 - 基本ケース

引数の値:

• 左側で選択する列の条件:
  allColumns(
  
  )
• 右側で選択する列の条件:
  columnNameIsIn(
   columnNames: [home_airport],
  )
• 結合条件: [(tail_number, tail_number)]
• 左側のデータセット: ri.foundry.main.dataset.left
• 右側のデータセット: ri.foundry.main.dataset.right
• 右側からの列の接頭辞: null 入力: ri.foundry.main.dataset.leftri.foundry.main.dataset.right出力: | tail_number | airline | miles | factor | home_airport | | ----- | ----- | ----- | ----- | ----- | | XB-123 | foundry air | 124 | 2 | LHR | | XB-123 | foundry air | 124 | 2 | LGW | | MT-222 | new airline | 1123 | 5 | CPH | | XB-123 | foundry airline | 335 | 5 | LHR | | XB-123 | foundry airline | 335 | 5 | LGW | | MT-222 | new air | 565 | 4 | CPH | | KK-452 | new air | 222 | 1 | JFK | | PA-452 | new air | 212 | 2 | null | | XB-123 | foundry airline | 1134 | 2 | LHR | | XB-123 | foundry airline | 1134 | 2 | LGW |

---