从 Flink 文档中,我看到有两个不同的窗口对象:
timeWindow(Time.seconds(5))而且window(TumblingWindow/SlidingWindow) ....,我对它们之间的区别感到困惑,尤其是timeWindow,它是 aSlidingWindow还是TumblingWindow?
timeWindow(Time)的 JavaDoc明确指出它是.window(TumblingEventTimeWindows.of(size))或的快捷方式.window(TumblingProcessingTimeWindows.of(size)),具体取决于流的时间特征。所以是的,它是一个 TumblingWindow。
| 归档时间: |
|
| 查看次数: |
421 次 |
| 最近记录: |