Flink中window和timewindow有什么区别
What is the difference of window and timewindow in Flink
从 Flink 文档中我看到有两个不同的 window 对象:
timeWindow(Time.seconds(5))
还有 window(TumblingWindow/SlidingWindow) ....
,
我对它们之间的区别感到困惑,尤其是 timeWindow
,它是 SlidingWindow
还是 TumblingWindow
?
timeWindow(Time) 的 JavaDoc 明确指出它是 .window(TumblingEventTimeWindows.of(size))
或 .window(TumblingProcessingTimeWindows.of(size))
的快捷方式,具体取决于流的时间特征。所以是的,这是一个 TumblingWindow。
从 Flink 文档中我看到有两个不同的 window 对象:
timeWindow(Time.seconds(5))
还有 window(TumblingWindow/SlidingWindow) ....
,
我对它们之间的区别感到困惑,尤其是 timeWindow
,它是 SlidingWindow
还是 TumblingWindow
?
timeWindow(Time) 的 JavaDoc 明确指出它是 .window(TumblingEventTimeWindows.of(size))
或 .window(TumblingProcessingTimeWindows.of(size))
的快捷方式,具体取决于流的时间特征。所以是的,这是一个 TumblingWindow。