MR_shuffle流程筆記

下面是我一些對流程源碼的理解 還是WordCount案例，進入到context.write()方法 進入到mapContext.write()方法 進入到write方法 在進入到write方法 可以看到有一個collectorc.collect()方法 其中getPartition()作用是獲得當前數據的分區號 我們進入這個方法 因爲我自定義了partition並指定了分區類 所以執行的是我重寫過

>>阅读原文<<