flink中對於window和watermark的一些理解

首先window的時間範圍是一個天然時間範圍，好比你定義了一個java TumblingEventTimeWindows.of(Time.seconds(3)) 窗口，那麼會生成相似以下的窗口(左閉右開)：apache [2018-03-03 03:30:00,2018-03-03 03:30:03)windows [2018-03-03 03:30:03,2018-03-03 03:30:06)

>>阅读原文<<