Spark TaskScheduler的源碼圖解

TaskScheduler模塊用於與DAGScheduler交互,負責任務的具體調度和運行。任務調度模塊基於兩個Trait:TaskScheduler和 SchedulerBackend。 TaskScheduler:定義了任務調度模塊的對外接口(submitTasks等),供DAGScheduler調用。 TaskSchedulerImpl是TaskScheduler的具體實現,完成資源與任務的
相關文章
相關標籤/搜索