我这边first感觉没起作用，还是把所有的都打印出来了

来源：4-20 Transformation函数first之Java实现

威先森

2019-09-18

    public static void firstFunction(ExecutionEnvironment env) throws Exception {
        //1.设置输入的数据
        List<Tuple2<Integer, String>> list = new ArrayList<>(10);
        list.add(new Tuple2<Integer, String>(1,"a1"));
        list.add(new Tuple2<Integer, String>(3,"a3"));
        list.add(new Tuple2<Integer, String>(5,"a5"));
        list.add(new Tuple2<Integer, String>(4,"a4"));
        list.add(new Tuple2<Integer, String>(2,"a2"));
        list.add(new Tuple2<Integer, String>(8,"a8"));
        list.add(new Tuple2<Integer, String>(6,"a6"));
        list.add(new Tuple2<Integer, String>(10,"a10"));
        list.add(new Tuple2<Integer, String>(7,"a7"));
        list.add(new Tuple2<Integer, String>(9,"a9"));
        //2.读取输入的数据
        DataSource<Tuple2<Integer, String>> data = env.fromCollection(list);
//        data.first(3).print();
//        System.out.println("----------------------");
        data.groupBy(0)
                .first(3)
                .print();
//        System.out.println("----------------------");
//        data.groupBy(0).sortGroup(1, Order.DESCENDING).first(2).print();
    }

写回答

2回答

Michael_PK

2019-09-19

已采纳

你把数据和代码都贴出来，而且图片那么模糊，看不清

威先森

非常感谢！

2019-09-25

共1条回复

威先森

提问者

2019-09-19

    public static void firstFunction(ExecutionEnvironment env) throws Exception {
        //1.设置输入的数据
        List<Tuple2<Integer, String>> list = new ArrayList<>(10);
        list.add(new Tuple2<Integer, String>(1,"a1"));
        list.add(new Tuple2<Integer, String>(3,"a3"));
        list.add(new Tuple2<Integer, String>(5,"a5"));
        list.add(new Tuple2<Integer, String>(4,"a4"));
        list.add(new Tuple2<Integer, String>(2,"a2"));
        list.add(new Tuple2<Integer, String>(8,"a8"));
        list.add(new Tuple2<Integer, String>(6,"a6"));
        list.add(new Tuple2<Integer, String>(10,"a10"));
        list.add(new Tuple2<Integer, String>(7,"a7"));
        list.add(new Tuple2<Integer, String>(9,"a9"));
        //2.读取输入的数据
        DataSource<Tuple2<Integer, String>> data = env.fromCollection(list);
//        data.first(3).print();
//        System.out.println("----------------------");
        data.groupBy(0)
                .first(3)
                .print();
//        System.out.println("----------------------");
//        data.groupBy(0).sortGroup(1, Order.DESCENDING).first(2).print();
    }

Michael_PK

威先森

哈哈，你可以多造点数据测试下

2019-09-20

共4条回复

新一代大数据计算引擎 Flink从入门到实战

入行或转型大数据新姿势，多语言系统化讲解，极速入门Flink

969 学习 · 296 问题

查看课程

相似问题

看了一天，能不能本地写一个完整的job，打jar包，提交flink上，写入ES的

回答 4