ChangeBy


ChangeBy()操作分区、排序、并且计算输入数据集里的每条数据记录值跟上一条记录值的变化。

  • unit: (必需提供) STRING格式。计算每一行变化的单位的的表达式。
  • value: (必需提供) STRING格式。计算每一行变化的值的的表达式。
  • keys: (非提供) STRING格式。 标识主键的表达式,多列以逗号分隔。
  • sorts: (非必需) STRING格式。标识数据序列里用以排序的表达式,多表达式以逗号分隔。
  • partitionized: (非必需) BOOLEAN格式。变化是否在每个分区内各自做。默认值为FALSE。
  • default_value: (非必需) STRING格式。每一行如果值为空时的默认值表达式。
  • unit_change_name: (非必需) STRING格式。新增加的单位变化的列名。默认值为'unit_change'。
  • value_change_name: (非必需) STRING格式。新增加的值变化的列名。默认值为'value_change'。