深刻理解Spark 2.1 Core (九):迭代计算和Shuffle的原理与源码分析

在博文《深刻理解Spark 2.1 Core (七):任务执行的原理与源码分析 》咱们曾讲到过:java Task有两个子类,一个是非最后的Stage的Task,ShuffleMapTask;一个是最后的Stage的Task,ResultTask。它们都覆盖了Task的runTask方法。web 咱们来看一下ShuffleMapTask的runTask方法中的部分代码:算法 var writer:
相关文章
相关标签/搜索