Task原理源码分析

在Executor类中的TaskRunner是执行Task的入口 进入updateDependencies（）函数 进入Task类中的run（）方法 在上面的Task的run方法中，调用了抽象方法，runTask（），那就意味着关键的操作都要依赖于子类的实现，Task的子类ShuffleMapTask，ResultTask，要运行它们的runTask，才能执行我们自定义的算子和逻辑 接下来是先进入

>>阅读原文<<