Left lookup join

対応環境: Streaming

2 つのデータセットを結合し、左側のテーブルからすべての行を保持し、右側のテーブルから一致する行のみを保持します。

トランスフォームカテゴリ: Join

引数

• 左側で選択する列の条件 - 左側の入力スキーマ内のすべての列がこの条件と一致するかどうかをテストします。一致する場合、列は出力に選択されます。
  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.left

ri.foundry.main.dataset.right

出力:

---

例 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.left

ri.foundry.main.dataset.right

出力:

---

例 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.left

ri.foundry.main.dataset.right

出力:

---