Flink窗口类型功能汇总

Flink窗口类型功能汇总

Flink 中的 WindowAssigner 有多种实现类，每种实现类都有不同的作用。以下是一些常见的 WindowAssigner 实现类：

1. TumblingEventTimeWindows：
   将事件时间划分为固定大小的窗口。

2. SlidingEventTimeWindows：
   将事件时间划分为固定大小的窗口，但窗口之间存在重叠。

3. SessionWindows：
   将事件时间划分为会话窗口，会话窗口由连续的事件组成，当一段时间内没有事件发生时，会话窗口结束。

4. GlobalWindows：
   将整个数据流视为一个窗口。

5. ProcessingTimeWindows：
   将处理时间划分为固定大小的窗口。

6. SlidingProcessingTimeWindows：
   将处理时间划分为固定大小的窗口，但窗口之间存在重叠。

7. CountWindows：
   将数据流划分为固定数量的元素的窗口。

8. SlidingCountWindows：
   将数据流划分为固定数量的元素的窗口，但窗口之间存在重叠。

9. DynamicCountWindows：
   将数据流划分为固定数量的元素的窗口，但窗口的大小可以动态调整。

10. DynamicSlidingCountWindows：
    将数据流划分为固定数量的元素的窗口，但窗口的大小可以动态调整，并且窗口之间存在重叠。