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

Window是無限數據流處理的核心，Window將一個無限的stream拆分紅有限大小的」buckets」桶，咱們能夠在這些桶上作計算操做。本文主要聚焦於在Flink中如何進行窗口操做，以及程序員如何從window提供的功能中得到最大的收益。 　　窗口化的Flink程序的通常結構以下，第一個代碼段中是分組的流，而第二段是非分組的流。正如咱們所見，惟一的區別是分組的stream調用keyBy(…)和

>>阅读原文<<