Flink操练（二十七）之shuffle三种实现方式

　　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> 1 shuffle::2> 2 broadcast::1> 1 shuffle::1> 1 rebalance::2> 2 broadcast::2> 1 rebalance::2> 4 shuffle::1> 3 broadcast::1> 2 rebalance::1> 3 broadcast::1> 3 broadcast::1> 4 shuffle::1> 4 broadcast::2> 2 broadcast::2> 3 broadcast::2> 4 Process finished with exit code 0