Task原理源碼分析

在Executor類中的TaskRunner是執行Task的入口 進入updateDependencies()函數 進入Task類中的run()方法 在上面的Task的run方法中,調用了抽象方法,runTask(),那就意味着關鍵的操作都要依賴於子類的實現,Task的子類ShuffleMapTask,ResultTask,要運行它們的runTask,才能執行我們自定義的算子和邏輯 接下來是先進入
相關文章
相關標籤/搜索