Flink中window和timewindow有什么区别

MJe*_*emy 2 flink-streaming

从 Flink 文档中,我看到有两个不同的窗口对象: timeWindow(Time.seconds(5))而且window(TumblingWindow/SlidingWindow) ....,我对它们之间的区别感到困惑,尤其是timeWindow,它是 aSlidingWindow还是TumblingWindow?

kkr*_*ler 5

timeWindow(Time)的 JavaDoc明确指出它是.window(TumblingEventTimeWindows.of(size))或的快捷方式.window(TumblingProcessingTimeWindows.of(size)),具体取决于流的时间特征。所以是的,它是一个 TumblingWindow。