Flink的Window與WindowAll 算子對比

案例:code 最大的區別,一個能夠設置並行度,一個不能設置並行度blog Window算子:是能夠設置並行度的class dataStream.keyBy(0).window(TumblingEventTimeWindows.of(Time.seconds(5))); WindowAll 算子:並行度始終爲1並行 dataStream.windowAll(TumblingEventTimeWin
相關文章
相關標籤/搜索