注: 以下の翻訳の正確性は検証されていません。AIPを利用して英語版の原文から機械的に翻訳されたものです。

アウタージョイン

Batchで対応しています

アウタージョインは、左と右のデータセットを結合します。変換カテゴリー：ジョイン

左側で選択する行の条件 - 左側の入力スキーマ内のすべての行がこの条件と一致するかどうかをテストします。一致する場合、その行は出力で選択されます。
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 Inputs: ri.foundry.main.dataset.leftri.foundry.main.dataset.rightOutput: | 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 | | JR-201 | null | IAD |

例 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_ Inputs: ri.foundry.main.dataset.leftri.foundry.main.dataset.rightOutput: | tail_number | airline | factor | right_tail_number | right_home_airport | right_factor | | ----- | ----- | ----- | ----- | ----- | ----- | | XB-123 | foundry air | 2 | KK-452 | JFK | 10 | | XB-123 | foundry air | 2 | JR-201 | IAD | 4 | | MT-222 | new airline | 5 | KK-452 | JFK | 10 | | XB-123 | foundry airline | 5 | KK-452 | JFK | 10 | | MT-222 | new air | 4 | KK-452 | JFK | 10 | | KK-452 | new air | 1 | XB-123 | LHR | 2 | | KK-452 | new air | 1 | KK-452 | JFK | 10 | | KK-452 | new air | 1 | JR-201 | IAD | 4 | | PA-452 | new air | 2 | KK-452 | JFK | 10 | | PA-452 | new air | 2 | JR-201 | IAD | 4 | | XB-123 | foundry airline | 2 | KK-452 | JFK | 10 | | XB-123 | foundry airline | 2 | JR-201 | IAD | 4 | | null | null | null | MT-222 | CPH | 1 |

例 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 Inputs: ri.foundry.main.dataset.leftri.foundry.main.dataset.rightOutput: | 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 | | JR-201 | null | 4 | IAD | | KK-452 | null | 10 | JFK | | MT-222 | null | 1 | CPH |

例 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 Inputs: ri.foundry.main.dataset.leftri.foundry.main.dataset.rightOutput: | tail_number | airline | miles | factor | home_airport | | ----- | ----- | ----- | ----- | ----- | | XB-123 | foundry air | 124 | 2 | LHR | | MT-222 | new airline | 1123 | 5 | CPH | | XB-123 | foundry airline | 335 | 5 | LHR | | 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 | | JR-201 | null | null | null | IAD |