网站介绍:文章浏览阅读880次,点赞2次,收藏8次。scala RDD算子map 当使用map时,对于List(1,2,3,4),前面分区后会分成两个区import org.apache.spark.rdd.RDDimport org.apache.spark.{SparkConf, SparkContext}object rdd_partiton_map { def main(args: Array[String]): Unit = { val sparkConf = new SparkConf().set("spark.tes_val rdd: rdd[int] = sc.makerdd(list(1,2,3,4)) rdd.map (num=>num).collect().f
- 链接地址:https://blog.csdn.net/weixin_47184299/article/details/120596066
- 链接标题:scala RDD算子_val rdd: rdd[int] = sc.makerdd(list(1,2,3,4)) rdd.-CSDN博客
- 所属网站:blog.csdn.net
- 被收藏次数:5518
- 网站标签:val rdd: rdd[int] = sc.makerdd(list(1 2 3 4)) rdd.map (num=>num).collect().f