Spark源码分析

一、 启动篇 (一) 引子 在spark-shell终端执行 val arr = Array(1,2,3,4) val rdd = sc.makeRDD(arr) rdd.collect 以上3行代码构成了一个完整的spark job执行。 (二) 启动篇