Flink时间窗和幻灯片时间窗有何不同？

Question

我正在调查Apache Flink如何工作并试图了解Flink中的时间窗口。

Answer 1

文档概述了本公：https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/windows.html

简单TimeWindow实际上是翻滚（事件/处理）TimeWindow和滑动（事件/处理）TimeWindow是一个滑动窗口。

为了从文档（参见链接插图）给出具体的例子：

翻滚窗口

翻滚窗口分配器的每个元素分配给 指定窗口大小的窗口。翻滚的窗户有固定的尺寸，不要重叠。例如，如果您指定大小为 5分钟的滚动窗口，则将评估当前窗口，并且每五分钟启动一个新窗口 。

推拉窗

滑动窗口分配器分配元件以固定 长度的窗口。与滚动窗口分配器类似，窗口大小参数配置了窗口的大小。额外的 窗口滑动参数控制启动滑动窗口的次数为 。因此，如果幻灯片比窗口大小小，则滑动窗口可以重叠。在这种情况下，元素被分配到 多个窗口。

例如，您可以使用大小为10分钟的窗口，该窗口在5分钟内滑动 。有了这个，你每隔5分钟就会得到一个窗口，其中包含在过去10分钟内到达的事件 。