窗口相关操作的总结

本文重点

在前面的课程中，我们学习了Flink中关于窗口的一系列操作，本文对前面的内容进行总结

总结内容

窗口类型

从窗口的驱动类型角度看，窗口可以分为时间窗口和计数窗口

从窗口的按照分配数据的规则来看，窗口可以分为滚动窗口和滑动窗口和会话窗口和全局窗口

将二者结合起来，我们可以得到滚动事件窗口、滚动计数窗口、滑动事件窗口、滑动计数窗口、会话时间窗口、全局窗口（需要依赖触发器）

窗口的类型和基本信息由窗口分配器指定，窗口不会预先创建好，当第一个应该属于这个窗口的数据元素到达时，才会创建对应的窗口。

是否分区

当我们有一个流DataStream的时候，我们要想生成窗口有两种方式，一种是直接开窗（相当于并行度为1，这种方式不常用），另外一种是先分区在开窗。

keyBy 之后的 KeyedStream，可以调 用.window()方法声明按键分区窗口（Keyed Windows）；而如果不做 keyBy，DataStream 也可 以直接调用.windowAll()声明非按键分区窗口。

开创完成之后要想回到DataStream需要经过窗口函数的处理，它们之间的转换关系如下：