左查找合并

支持于: 流式处理

将两个数据集合并，保留左表中的所有行以及右表中匹配的行。

变换类别: 合并

声明的参数

• 选择左边列的条件 - 将测试左边输入模式中的所有列是否符合此条件。如果符合，该列将被选中并输出。
  ColumnPredicate
• 选择右边列的条件 - 将测试右边输入模式中的所有列是否符合此条件。如果符合，该列将被选中并输出。
  ColumnPredicate
• 合并条件 - 从左和右输入中列出的列来进行合并。
  List<Tuple<Column<Boolean | Byte | Date | Double | Float | Integer | Long | Short | 字符串 | Timestamp>, Column<Boolean | Byte | Date | Double | Float | Integer | Long | Short | 字符串 | Timestamp>>>
• 左数据集 - 合并中使用的左数据集。
  Table
• 右数据集 - 合并中使用的右数据集。
  Table
• 非必填 右边列的前缀 - 为右侧所有列添加的前缀。
  Literal<字符串>

示例

示例 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

输出:

---