Flink组件三:window
3.Window
CountWindow TimeWindow
滚动窗口、滑动窗口、会话session窗口
3.1window的类型
3.1.1.countWindow使用
3.2.timeWindow使用
3.3.自定义window
3.2.window聚合
3.2.1.增量聚合
窗口中每进入一条数据,就进行一次计算
reduce(reduceFunction)
aggregate(aggregateFunction)
sum(),min(),max()
reduce:
aggregate
3.2.2.全量聚合
等属于窗口的数据到齐,才开始进行聚合计算【可以实现对窗口内的数据进行排序等需求】
apply(windowFunction)
process(processWindowFunction)
processWindowFunction比windowFunction提供了更多的上下文信息。
apply:
process: