161、Spark內核原理進階之repartition算子內部實現原理

看圖   repartition.png repartition算子,repartition算子=coalesce(true) map,附加了前綴,根據要重分區成幾個分區,計算出前綴 shuffle->colesceRDD 去掉前綴,得到最終重分區好的RDD
相關文章
相關標籤/搜索