spark--WordCount執行過程詳解

首先看一下WordCount代碼： val conf = new SparkConf().setAppName("ScalaWordCount").setMaster("local[4]") //創建spark執行的入口 val sc = new SparkContext(conf) //指定以後從哪裏讀取數據創建RDD（彈性分佈式數據集） val lines:RD

>>阅读原文<<