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分鐘內到達的事件 。