Spark任务提交与执行之RDD的建立、转换及DAG构建

在这里经过使用wordcount例子来学习Spark是如何进行任务的提交与执行。本次先进行RDD的建立、转换以及DAG的构建进行学习。 整个wordcount的代码能够简单以下实现：java sc.textFile("/library/wordcount/input").flatMap(_.split(" ")).map(word => (word, 1)).reduceByKey(_ + _).

>>阅读原文<<