Flink的Window与WindowAll 算子对比

mac2024-03-14  33

案例:

最大的区别,一个可以设置并行度,一个不能设置并行度

Window算子:是可以设置并行度的

dataStream.keyBy(0).window(TumblingEventTimeWindows.of(Time.seconds(5)));

WindowAll 算子:并行度始终为1

dataStream.windowAll(TumblingEventTimeWindows.of(Time.seconds(5)));

 

最新回复(0)