左参照結合

サポート対象：ストリーミング

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

データ加工のカテゴリー：結合

引数

• 左側で選択する列の条件： 左側の入力スキーマの各列がこの条件に一致するかどうかを判定します。一致した列が出力に含まれます。
  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
• 1行と結合する最大行数： 左側の1行と結合できる右側の入力の最大行数に制限を設けます。この制限に設定できる最大値は10です。制限を高く設定しすぎると、パフォーマンスに悪影響を及ぼす可能性があります。
  Literal<Integer>
• 右側のデータセット： 結合に使用する右側のデータセットです。
  Table
• 任意 右側の列の接頭辞： 右側のすべての列に追加する接頭辞です。
  Literal<String>

例

例1：基本ケース

引数の値：

• 左側で選択する列の条件：
  columnNameIsIn(
   columnNames: [tail_number, airline],
  )
• 右側で選択する列の条件：
  columnNameIsIn(
   columnNames: [home_airport],
  )
• 結合条件： [(tail_number, tail_number)]
• 左側のデータセット： ri.foundry.main.dataset.left
• 1行と結合する最大行数： 10
• 右側のデータセット： 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
• 1行と結合する最大行数： 10
• 右側のデータセット： 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
• 1行と結合する最大行数： 10
• 右側のデータセット： ri.foundry.main.dataset.right
• 右側の列の接頭辞： null

入力：

ri.foundry.main.dataset.left

ri.foundry.main.dataset.right

出力：

---