Flink】 Flink中的window窗口分类,及其作用是什么?

2021-01-20 16:28发布

2条回答
人情世故
2021-01-22 16:12
  • Keyed Window:上游数据集如果是 KeyedStream 类型,则调用 DataStream API 的 window()方法,数据会根据 Key 在不同的 Task 实例中并行分别计算,最后得出针对每个 Key 统计的结果。

  •  Global Window:如果是 Non-Keyed 类型,则调用 WindowsAll()方法,所有的数据都会71在窗口算子中由到一个 Task 中计算,并得到全局统计结果。


一周热门 更多>