然后我们再来看,窗口函数,上面我们说了,窗口的分类,如何利用窗口分配器,
来创建不同的窗口.
然后我们再来看,窗口创建以后,如何来处理窗口的数据,之类有两类:
窗口函数,可以看到,1.增量聚合函数 2.全窗口函数.
首先我们来看增量聚合函数,这里,可以看到,数据从左侧流过来,然后
碰到时间窗口,以后把数据放到一个桶里去,这个时候,比如做的是sum这种操作,那么就会
来一个数据,进行一次sum操作,来一个进行一次,最终当窗口结束的时候,实际上相当于
在桶中仅仅保存了,最后经过sum的,那个状态数据,用的时候,直接去取就可以了.
这种的就是增量聚合函数,以前我们用的ReduceFunction ,还有一个没用的
AggregateFunction,还有sum,min,max等都是增量聚合函数.