spark take获取前n个元素

元素"/>

spark take获取前n个元素

     take和 collect操作类似，都是从远程集群上获取元素，只是collect操作获取的所有数据，而take操作是获取前n个元素

直接上代码：

public static void myTake(){
        SparkConf conf=new SparkConf()
        .setMaster("local")
        .setAppName("myTake");
        
        JavaSparkContext sc=new JavaSparkContext(conf);
        List<Integer> numberList = Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 9, 10);
         JavaRDD<Integer> numRdd=sc.parallelize(numberList, 2);
         List<Integer> list=numRdd.take(4);
         for(Integer i:list){
             System.out.println("i:"+i);
         }
         sc.close();
        
    }

结果：

i:1
i:2
i:3
i:4