Spark函數講解：collect

將RDD轉成Scala數組，並返回。 函數原型 def collect(): Array[T] def collect[U: ClassTag](f: PartialFunction[T, U]): RDD[U]collect函數的定義有兩種，咱們最經常使用的是第一個。第二個函數須要咱們提供一個標準的偏函數，而後保存符合的元素到MappedRDD中。 實例 scala> val one: Part

>>阅读原文<<