特牛生活网

Spark基础API总结-CSDN博客

网友收藏
文章浏览阅读205次。1. keyValue(单个RDD操作)(1)collectAsMap(把keyvalue的类型转换成Map,去掉重复的,后面覆盖前面的)scala> val pairRDD = sc.parallelize[(Int, Int)](Seq((1, 2), (3, 4), (3, 6)), 2)pairRDD: org.apache.spark.rdd.RDD[(Int, Int)] = P..._spark基础api
标签:spark基础api