Flink的Window与WindowAll 算子对比

案例:code 最大的区别,一个能够设置并行度,一个不能设置并行度blog Window算子:是能够设置并行度的class dataStream.keyBy(0).window(TumblingEventTimeWindows.of(Time.seconds(5))); WindowAll 算子:并行度始终为1并行 dataStream.windowAll(TumblingEventTimeWin
相关文章
相关标签/搜索