Spark入門（五）：鍵值對RDD

1.建立PairRDD 普通RDD轉Pair RDD val rdd = sc.parallelize(Array("java","scala")) rdd.foreach(println) //java //scala val pairRdd = rdd.map(w => (w,"編程語言")) pairRdd.foreach(print) //(java,編程語言) //(scala,編程語言

>>阅读原文<<