Spark函数讲解：collect

将RDD转成Scala数组，并返回。 函数原型 def collect(): Array[T] def collect[U: ClassTag](f: PartialFunction[T, U]): RDD[U]collect函数的定义有两种，咱们最经常使用的是第一个。第二个函数须要咱们提供一个标准的偏函数，而后保存符合的元素到MappedRDD中。 实例 scala> val one: Part

>>阅读原文<<