Window窗口增量/全量聚合方法（reduce、aggrega
2020-07-28 本文已影响0人
程序男保姆
-
增量聚合
指窗口每进入一条数据就计算一次
image.png
实现方法
image.png
举例
reduce
image.png
aggregate
image.png
-
全量聚合
指在窗口触发的时候才会对窗口内的所有数据进行一次计算（等窗口的数据到齐，才开始进行聚合计算，可实现对窗口内的数据进行排序等需求）
image.png
实现方法
apply(windowFunction）
process(processWindowFunction）
举例
apply
image.png
process
image.png
