Flink 的Window 操做（基于flink 1.3描述）

Window是无限数据流处理的核心，Window将一个无限的stream拆分红有限大小的”buckets”桶，咱们能够在这些桶上作计算操做。本文主要聚焦于在Flink中如何进行窗口操做，以及程序员如何从window提供的功能中得到最大的收益。 　　窗口化的Flink程序的通常结构以下，第一个代码段中是分组的流，而第二段是非分组的流。正如咱们所见，惟一的区别是分组的stream调用keyBy(…)和

>>阅读原文<<