说明
将 不同分区 的 数据 按照 分区顺序 采集到 driver 端,组成数组并返回
声明
def collect(): Array[T]
返回值: Array数组
底层调用
例子
val sparConf = new SparkConf().setMaster("local[*]").setAppName("RDD")
val sc = new SparkContext(sparConf)
val rdd:RDD[Int] = sc.makeRDD( List( 1,2,3,4,5,6 ),2 )
rdd.collect()
sc.stop()

