セミジョイン

サポート対象: バッチ

セミジョインは左と右のデータセットを結合します。これにより、結合条件に一致しないすべての行が削除されます。

トランスフォームカテゴリ: ジョイン

引数

• 左側で選択する列の条件 - 左側の入力スキーマのすべての列がこの条件に一致するかテストされます。一致した場合、その列は出力に選択されます。
  ColumnPredicate
• ジョイン条件 - ジョインに使用する条件。
  Expression<Boolean>
• 左データセット - ジョインに使用する左データセット。
  Table
• 右データセット - ジョインに使用する右データセット。
  Table

例

例 1: 基本ケース

引数の値:

• 左側で選択する列の条件:
  columnNameIsIn(
   columnNames: [tail_number, airline],
  )
• ジョイン条件:
  equals(
   left: tail_number,
   right: tail_number,
  )
• 左データセット: ri.foundry.main.dataset.left
• 右データセット: ri.foundry.main.dataset.right

入力: ri.foundry.main.dataset.left

ri.foundry.main.dataset.right

出力:

---

例 2: 基本ケース

説明: シンプルな複合ジョイン条件。 引数の値:

• 左側で選択する列の条件:
  columnNameIsIn(
   columnNames: [tail_number, airline, factor],
  )
• ジョイン条件:
  and(
   conditions: [
  lessThan(
   left: factor,
   right: factor,
  ),
  equals(
   left: tail_number,
   right: tail_number,
  )],
  )
• 左データセット: ri.foundry.main.dataset.left
• 右データセット: ri.foundry.main.dataset.right

入力: ri.foundry.main.dataset.left

ri.foundry.main.dataset.right

出力:

---

例 3: 基本ケース

引数の値:

• 左側で選択する列の条件:
  columnNameIsIn(
   columnNames: [tail_number, airline, factor],
  )
• ジョイン条件:
  and(
   conditions: [
  equals(
   left: tail_number,
   right: tail_number,
  ),
  equals(
   left: factor,
   right: factor,
  )],
  )
• 左データセット: ri.foundry.main.dataset.left
• 右データセット: ri.foundry.main.dataset.right

入力: ri.foundry.main.dataset.left

ri.foundry.main.dataset.right

出力:

---

例 4: 基本ケース

引数の値:

• 左側で選択する列の条件:
  allColumns(
  
  )
• ジョイン条件:
  equals(
   left: tail_number,
   right: tail_number,
  )
• 左データセット: ri.foundry.main.dataset.left
• 右データセット: ri.foundry.main.dataset.right

入力: ri.foundry.main.dataset.left

ri.foundry.main.dataset.right

出力:

---