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,编程语言

>>阅读原文<<