首页
mac
it
登录
6mi
u
盘
搜
搜 索
it
Flink的Window与WindowAll 算子对比
Flink的Window与WindowAll 算子对比
mac
2024-03-14
33
案例:
最大的区别,一个可以设置并行度,一个不能设置并行度
Window算子:是可以设置并行度的
dataStream.keyBy(0).window(TumblingEventTimeWindows.of(Time.seconds(5)));
WindowAll 算子:并行度始终为1
dataStream.windowAll(TumblingEventTimeWindows.of(Time.seconds(5)));
转载请注明原文地址: https://mac.8miu.com/read-486121.html
最新回复
(
0
)