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)
相关文章
相关标签/搜索