HoppingWindow


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

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