4.2 窗口类型

前面提到过对数据集进行切分的概念，为此Flink中提供了3类默认窗口：计数窗口（Count Window）、时间窗口（Time Window）和会话窗口（Session Window）。

不同类型的窗口及其示例如图4-2所示。

图4-2 窗口类型

1. Count Window

1）Tumble Count Window：累积固定个数的元素就视为一个窗口，该类型的窗口无法像时间窗口一样事先切分好。

2）Sliding Count Window：累积固定个数的元素视为一个窗口，每超过一定个数的原则个数，则产生一个新的窗口。

2. Time Window

1）Tumble Time Window：表示在时间上按照事先约定的窗口大小切分的窗口，窗口之间不会相互重叠。

2）Sliding Time Window：表示在时间上按照事先约定的窗口大小、滑动步长切分的窗口，滑动窗口之间可能会存在相互重叠的情况。

3. Session Window

Session Window是一种特殊的窗口，当超过一段时间，该窗口没有收到新的数据元素，则视为该窗口结束，所以无法事先确定窗口的长度、元数个数，窗口之间也不会相互重叠。