Flink组件三:window

3.Window

CountWindow TimeWindow
滚动窗口、滑动窗口、会话session窗口
Flink组件三:window

3.1window的类型

3.1.1.countWindow使用

Flink组件三:window

3.2.timeWindow使用

Flink组件三:window

3.3.自定义window

Flink组件三:window

3.2.window聚合

3.2.1.增量聚合

窗口中每进入一条数据,就进行一次计算
reduce(reduceFunction)
aggregate(aggregateFunction)
sum(),min(),max()
Flink组件三:window
reduce:
Flink组件三:window
aggregate
Flink组件三:window

3.2.2.全量聚合

等属于窗口的数据到齐,才开始进行聚合计算【可以实现对窗口内的数据进行排序等需求】
apply(windowFunction)
process(processWindowFunction)
processWindowFunction比windowFunction提供了更多的上下文信息。
Flink组件三:window
apply:
Flink组件三:window
process:
Flink组件三:window
Flink组件三:window