spark源碼系列03-任務提交01

用spark版本1.3+ val conf=new SparkConf().setAppName("WordCount")     val sc=new SparkContext(conf)     //構建RDD並調用Transformation     //textFile創建一個hadoopRdd，產生一個MapPartitionsRDD      //flatMap 產生一個MapPart

>>阅读原文<<