1、代码逻辑实现packageday02;importorg。apache。flink。streaming。api。environment。StreamExecutionEnvironment;program:Flinklearndescription:shuffle三种方式author:Mr。逗create:2021091711:38publicclassShuffle{publicstaticvoidmain(String〔〕args){StreamExecutionEnvironmentenvStreamExecutionEnvironment。getExecutionEnvironment();1、shuffleenv。fromElements(1,2,3,4)。setParallelism(1)。shuffle()。print(shuffle:)。setParallelism(2);2、rebalanceenv。fromElements(1,2,3,4)。rebalance()。print(rebalance:)。setParallelism(2);3、broadcastenv。fromElements(1,2,3,4)。broadcast()。print(broadcast:)。setParallelism(2);StringnameShuffle。class。getName();try{env。execute(name);}catch(Exceptione){e。printStackTrace();}}}2、结果之展示rebalance::11shuffle::22broadcast::11shuffle::11rebalance::22broadcast::21rebalance::24shuffle::13broadcast::12rebalance::13broadcast::13broadcast::14shuffle::14broadcast::22broadcast::23broadcast::24Processfinishedwithexitcode0