Из документации Flink я вижу два разных оконных объекта: timeWindow(Time.seconds(5)), а также window(TumblingWindow/SlidingWindow) ...., Меня смущает разница между ними, особенно timeWindow, это SlidingWindow или TumblingWindow?
timeWindow(Time.seconds(5))
window(TumblingWindow/SlidingWindow) ....
timeWindow
SlidingWindow
TumblingWindow
JavaDoc для timeWindow (Time) прямо говорит, что это ярлык для .window(TumblingEventTimeWindows.of(size)) или .window(TumblingProcessingTimeWindows.of(size)), в зависимости от временной характеристики потока. Так что да, это TumblingWindow.
.window(TumblingEventTimeWindows.of(size))
.window(TumblingProcessingTimeWindows.of(size))