Flink DataSet first groupBy sortGroup 用法 实例

本文主要是介绍Flink DataSet first groupBy sortGroup 用法 实例，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

public class CoGroupDataSetTest {public static void main(String[] args) throws Exception {ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();//注意：可启用这行代码看区别//env.setParallelism(1);DataSet<Tuple2<Long, String>> source1 = env.fromElements(Tuple2.of(1L, "xiaoming"),Tuple2.of(2L, "xiaowang"));DataSet<Tuple2<Long, String>> source2 = env.fromElements(Tuple2.of(2L, "xiaoli"),Tuple2.of(1L, "shinelon"),Tuple2.of(2L, "xiaohong"),Tuple2.of(3L, "hhhhhh"));source2.sortPartition(0, Order.ASCENDING).print();//(1,shinelon)//(2,xiaoli)//(2,xiaohong)//(3,hhhhhh)System.out.println("------");//先按第一个字段排升序，再按第二个字段排升序，= 

这篇关于Flink DataSet first groupBy sortGroup 用法 实例的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---