spark--WordCount执行过程详解

首先看一下WordCount代码： val conf = new SparkConf().setAppName("ScalaWordCount").setMaster("local[4]") //创建spark执行的入口 val sc = new SparkContext(conf) //指定以后从哪里读取数据创建RDD（弹性分布式数据集） val lines:RD

>>阅读原文<<