Spark makeRDD partitioned RDD源码分析

    object Spark_MakeRDD {
    def main(args: Array[String]): Unit = {
    
        val sparkConf = new SparkConf().setMaster("local[*]").setAppName("List-RDD")
    
        val sc : SparkContext = new SparkContext(sparkConf)
        
        // 设置3个分区
        val rdd = sc.makeRDD(List(1,2,3,4,5), 3)
        
        // 保存到output文件夹中
        rdd.saveAsTextFile("output")
        
        sc.stop()
    }
    }