SlidingWindow


SlidingWindow()操作对输入数据集里每行数据的移动窗口进行表达式计算。 支持的窗口函数包括 wfirst、wlast、wsum、wmax、wmin、wavg、wcount、wsize、wsumif、wcountif。

  • inclusion: (必需提供) STRING格式。 标识移动窗口的表达式,每一行数据对现有窗口解析,所有结果为FALSE的窗口数据将以FIFO机制移出。
  • selects: (必需提供) STRING格式。计算的表达式, 例: wsum('field2'), wmax('field3'), wlast('field4', 1)...,多列以逗号分隔。
  • validity: (非必需) STRING格式。检查窗口是否有效的Boolean表达式。TRUE为有效,默认值为空(所有窗口都有效)。
  • keys: (非必需) STRING格式。 标识key对象的表达式,多列以逗号分隔。
  • sorts: (非必需) STRING格式。标识数据序列里用以排序的表达式。
  • partitions: (非必需) INT格式。 分布式分区的数量(如果需要重新分布)。默认值为0(保持现有的数据分布)。