我正在调查Apache Flink是如何工作的,并试图理解Flink中的时间窗口。
发布于 2017-10-20 23:32:19
文档很好地概括了这一点:https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/windows.html
简单的TimeWindow实际上是翻滚(事件/处理)TimeWindow,而滑动(事件/处理)TimeWindow是滑动窗口。
要提供文档中的特定示例(请参阅插图链接),请执行以下操作:
翻滚窗口
翻滚窗口分配器将每个元素分配给指定窗口大小的窗口。翻滚窗口具有固定大小且不重叠。例如,如果您指定一个大小为5分钟的翻滚窗口,则将评估当前窗口,并每隔5分钟启动一个新窗口。
滑动窗口
滑动窗口分配器将元素分配给固定长度的窗口。与翻滚窗口分配器类似,窗口大小由窗口大小参数配置。另一个窗口滑动参数控制滑动窗口的启动频率。因此,如果幻灯片小于窗口大小,则滑动窗口可以重叠。在这种情况下,元素被分配给多个窗口。
例如,您的窗口大小为10分钟,而滑动时间为5分钟。这样,您每隔5分钟就会得到一个窗口,其中包含在过去10分钟内到达的事件。
https://stackoverflow.com/questions/46849855
复制相似问题