Flink ---窗口机制

背景   在流计算中，数据流是无限的，无法直接进行计算，因此Flink提出了window的概念（若干元素的集合）作为流计算的基本单元进行数据处理。 窗口机制   窗口机制实质上是Flink的算子operator对数据流的处理过程：数据流如何被拆分成window，何时触发计算逻辑等，如下图所示。   处理过程： 当数据流中的元素到达算子operator后，首先由WindowAssigner决定将该元

>>阅读原文<<