Outer join

サポートされている形式: バッチ

外部結合は提供されたデータセット入力を一緒に結合し、両方のデータセットからすべての行を保持します。指定された条件を満たす行がない場合、列にはnullが含まれます。

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

引数

• 左側で選択する列の条件 - 左側の入力スキーマ内のすべての列がこの条件に一致するかどうかをテストします。一致する場合、列は出力に選択されます。
  ColumnPredicate
• 右側で選択する列の条件 - 右側の入力スキーマ内のすべての列がこの条件に一致するかどうかをテストします。一致する場合、列は出力に選択されます。
  ColumnPredicate
• 結合条件 - 結合する条件。
  Expression<Boolean>
• 左側のデータセット - 結合に使用する左側のデータセット。
  Table
• 右側のデータセット - 結合に使用する右側のデータセット。
  Table
• オプション 右側の列に追加する接頭辞 - 右側のすべての列に追加する接頭辞。
  Literal<String>

例

例 1: 基本ケース

引数の値:

• 左側で選択する列の条件:
  columnNameIsIn(
   columnNames: [tail_number, airline],
  )
• 右側で選択する列の条件:
  columnNameIsIn(
   columnNames: [home_airport],
  )
• 結合条件:
  equals(
   left: tail_number,
   right: 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: [tail_number, home_airport, factor],
  )
• 結合条件:
  lessThan(
   left: factor,
   right: factor,
  )
• 左側のデータセット: ri.foundry.main.dataset.left
• 右側のデータセット: ri.foundry.main.dataset.right
• 右側の列に追加する接頭辞: right_

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

ri.foundry.main.dataset.right

出力:

---

例 3: 基本ケース

引数の値:

• 左側で選択する列の条件:
  columnNameIsIn(
   columnNames: [tail_number, airline, factor],
  )
• 右側で選択する列の条件:
  columnNameIsIn(
   columnNames: [home_airport],
  )
• 結合条件:
  and(
   conditions: [
  equals(
   left: tail_number,
   right: tail_number,
  ),
  equals(
   left: factor,
   right: factor,
  )],
  )
• 左側のデータセット: ri.foundry.main.dataset.left
• 右側のデータセット: ri.foundry.main.dataset.right
• 右側の列に追加する接頭辞: null

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

ri.foundry.main.dataset.right

出力:

---

例 4: 基本ケース

説明: tail_numberの左と右の値は合成されることに注意。 引数の値:

• 左側で選択する列の条件:
  allColumns(
  
  )
• 右側で選択する列の条件:
  columnNameIsIn(
   columnNames: [home_airport],
  )
• 結合条件:
  equals(
   left: tail_number,
   right: tail_number,
  )
• 左側のデータセット: ri.foundry.main.dataset.left
• 右側のデータセット: ri.foundry.main.dataset.right
• 右側の列に追加する接頭辞: null

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

ri.foundry.main.dataset.right

出力:

---