说明
相当于 scala 集合中的 take() ，返回一个数组，该数组由 RDD 的前 n 个元素组成的
声明
def take(num: Int): Array[T]
形参：
- num：前 num 个元素
返回值： 前 n 个元素组成的 Array
例子
val sparConf = new SparkConf().setMaster("local[*]").setAppName("RDD")
val sc = new SparkContext(sparConf)
val rdd:RDD[Int] = sc.makeRDD( Array( 1,2,3,4,5,6 ),2 )
val res:Array[Int]=rdd.take(3)
println(s"res:${res.mkString(",")}")
res.foreach(println)
sc.stop()
执行结果：
res:1,2,3
1
2
3