1、程式碼邏輯實現
package day02；import org。apache。flink。streaming。api。environment。StreamExecutionEnvironment；/** * @program： Flink_learn * @description： shuffle三種方式 * @author： Mr。逗 * @create： 2021-09-17 11：38 **/public class Shuffle { public static void main（String［］ args） { StreamExecutionEnvironment env = StreamExecutionEnvironment。getExecutionEnvironment（）； //1、shuffle env。fromElements（1，2，3，4）。setParallelism（1）。shuffle（）。print（“shuffle：”）。setParallelism（2）； //2、rebalance env。fromElements（1，2，3，4）。rebalance（）。print（“rebalance：”）。setParallelism（2）； //3、broadcast env。fromElements（1，2，3，4）。broadcast（）。print（“broadcast：”）。setParallelism（2）； String name = Shuffle。class。getName（）； try { env。execute（name）； }catch （Exception e） { e。printStackTrace（）； } }}
2、結果之展示
rebalance：：1> 1shuffle：：2> 2broadcast：：1> 1shuffle：：1> 1rebalance：：2> 2broadcast：：2> 1rebalance：：2> 4shuffle：：1> 3broadcast：：1> 2rebalance：：1> 3broadcast：：1> 3broadcast：：1> 4shuffle：：1> 4broadcast：：2> 2broadcast：：2> 3broadcast：：2> 4Process finished with exit code 0
