然后我们再来看,增量聚合函数,上一节我们已经说了.
主要包含了,我们之前用过的,reduce,sum,min,max等,需要实现ReduceFunction
或者AggregateFunction对吧.我们是先使用timeWindow(Time.seconds(15))开窗以后,
然后再使用reduce,sum,min,max,或者aggregate开窗函数的对吧.
然后我们再来看,全窗口函数怎么使用.
上面都是,数据来了以后,实时处理的,是来一个数据处理一个,这个全窗口,就是一个窗口的数据
都到齐了以后再处理的.
可以看到这里,需要用到这个.apply方法
