2021-01-20 16:28发布
Keyed Window:上游数据集如果是 KeyedStream 类型,则调用 DataStream API 的 window()方法,数据会根据 Key 在不同的 Task 实例中并行分别计算,最后得出针对每个 Key 统计的结果。
Global Window:如果是 Non-Keyed 类型,则调用 WindowsAll()方法,所有的数据都会71在窗口算子中由到一个 Task 中计算,并得到全局统计结果。
最多设置5个标签!
Keyed Window:上游数据集如果是 KeyedStream 类型,则调用 DataStream API 的 window()方法,数据会根据 Key 在不同的 Task 实例中并行分别计算,最后得出针对每个 Key 统计的结果。
Global Window:如果是 Non-Keyed 类型,则调用 WindowsAll()方法,所有的数据都会71在窗口算子中由到一个 Task 中计算,并得到全局统计结果。
一周热门 更多>