scala RDD算子_val rdd: rdd[int] = sc.makerdd(list(1,2,3,4)) rdd.-CSDN博客

网站介绍:文章浏览阅读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