Spark 雜記--- 鍵值對操做RDD

一、 將一個普通的RDD轉換爲鍵值對RDD時，能夠經過調用map()函數來實現，傳遞的函數須要返回鍵值對。   scala 版:java scala> val lines =sc.parallelize(List("pandas","i like pandas")); lines: org.apache.spark.rdd.RDD[String] = ParallelCollectionRDD[0

>>阅读原文<<