DAGScheduler

https://zhuanlan.zhihu.com/p/165158261 具体来说DAGScheduler的功能如下： 1.划分和创建Stage：根据RDD之间的依赖类型（窄依赖或宽依赖），为每个Job划分和创建Stage，多个Stage之间相互依赖，形成一个DAG（有向无环图）。 2.决定运行 ......