深入理解Spark:核心思想与源码分析. 3.8 TaskScheduler的启动
3.8 TaskScheduler的启动 3.6节介绍了任务调度器TaskScheduler的创建,要想TaskScheduler发挥作用,必须要启动它,代码如下。 taskScheduler.start() TaskScheduler在启动的时候,实际调用了backend的start方法。 override def start() { backend.start() } 以LocalBackend为例,启动LocalBackend时向actorSystem注册了LocalActor,见代码清单3-30所示。 3.8.1 创建LocalActor 创建LocalActor的过程主要是构建本地的Executor,见代码清单3-36。 代码清单3-36 LocalActor的实现 private[spark] class Local