spark core源碼閱讀-Storage shuffle(八)

spark core源碼閱讀-Storage shuffle(八) 本節主要介紹RDD.aggregateByKey致使的shuffle,分兩部分map shuffle,reduce shufflegit 一 map shuffle ShuffleMapTask中Task如何處理rdd.iterator,shuffle中Map端如何根據根據分區把數據寫入文件.github 主要類簡述 Shuffl

>>阅读原文<<