条件下的聚合

支持于：批处理

基于条件语句的聚合表达式。

变换类别: 聚合

声明的参数

• 用于聚合的列的条件 - 将测试输入模式中的所有列，查看它们是否匹配此条件。如果匹配，将对它们应用给定的表达式。
  ColumnPredicate
• 数据集 - 需要操作的数据集。
  Table
• 要聚合的表达式 - 对每个匹配条件的列应用一次的聚合表达式。
  List<Expression<AnyType>>
• 非必填 按列分组 - 聚合时按列分组的数据集列表。如果为空，则不应用分组。
  List<Column<AnyType>>

示例

示例 1: 边缘情况

描述: 统计所有列中非空行的数量。 参数值:

• 用于聚合的列的条件:
  allColumns(
  
  )
• 数据集: ri.foundry.main.dataset.a
• 要聚合的表达式: [
  dynamicAlias(
   expression:
  rowCount(
   expression: column,
  ),
   transformer:
  columnNameConcat(
   inputs: [column, _non_null],
  ),
  )]
• 按列分组: null

输入:

输出:

---

示例 2: 边缘情况

描述: 统计非空整数列的数量和均值。 参数值:

• 用于聚合的列的条件:
  columnHasType(
   type: Integer,
  )
• 数据集: ri.foundry.main.dataset.a
• 要聚合的表达式: [
  dynamicAlias(
   expression:
  rowCount(
   expression: column,
  ),
   transformer:
  columnNameConcat(
   inputs: [column, _non_null],
  ),
  ),
  dynamicAlias(
   expression:
  mean(
   expression: column,
  ),
   transformer:
  columnNameConcat(
   inputs: [column, _mean],
  ),
  )]
• 按列分组: null

输入:

输出:

---

示例 3: 边缘情况

参数值:

• 用于聚合的列的条件:
  columnHasType(
   type: Integer,
  )
• 数据集: ri.foundry.main.dataset.a
• 要聚合的表达式: [
  dynamicAlias(
   expression:
  mean(
   expression: column,
  ),
   transformer:
  columnNameConcat(
   inputs: [column, _mean],
  ),
  )]
• 按列分组: [id]

输入:

输出:

---

示例 4: 边缘情况

描述: 所有整数列的均值。 参数值:

• 用于聚合的列的条件:
  columnHasType(
   type: Integer,
  )
• 数据集: ri.foundry.main.dataset.a
• 要聚合的表达式: [
  dynamicAlias(
   expression:
  mean(
   expression: column,
  ),
   transformer:
  columnNameConcat(
   inputs: [column, _mean],
  ),
  )]
• 按列分组: null

输入:

输出: