dagScheduler.runJob
2017-03-14 15:12:39 0 举报
`dagScheduler.runJob` 是一个用于在分布式任务调度系统中执行作业的方法。它允许用户提交一个作业,并将其添加到作业调度器的任务队列中。作业调度器会按照预定的调度策略,将作业分配给相应的工作节点进行处理。这个方法通常用于执行长时间运行的计算任务,例如数据清洗、数据分析等。通过使用 `dagScheduler.runJob`,用户可以有效地管理和监控作业的执行状态,确保任务按时完成。
作者其他创作
大纲/内容
event
DAGSchedulerEventProcessLoop (传入 dagScheduler 实例)
dagSchedulersubmitJob: getJobID eventProcessLoop.post waithandleJobSubmitted 具体的执行 job 执行完后notify wait 的线程
eventQueue
threadJobSubmittedJobCancelledExecutorAddedExecutorLost......全部代理给 dagScheduler对应的方法
0 条评论
下一页