大数据:Spark Core(四)用LogQuery的例子来说明Executor是如何运算RDD的算子_logqueryser服务-CSDN博客

网站介绍:文章浏览阅读3.3k次。1. 究竟是怎么运行的?很多的博客里大量的讲了什么是RDD, Dependency, Shuffle... 但是究竟那些Executor是怎么运行你提交的代码段的?下面是一个日志分析的例子,来自Spark的example def main(args: Array[String]) { val sparkConf = new SparkConf().setAppName("Log Quer_logqueryser服务