Window窗口增量/全量聚合方法（reduce、aggrega

• 增量聚合
  指窗口每进入一条数据就计算一次

  
  image.png

实现方法

image.png

举例
reduce

image.png

aggregate

image.png

• 全量聚合
  指在窗口触发的时候才会对窗口内的所有数据进行一次计算（等窗口的数据到齐，才开始进行聚合计算，可实现对窗口内的数据进行排序等需求）

  
  image.png

实现方法
apply(windowFunction）
process(processWindowFunction）
举例
apply

image.png

process

image.png