需要重點明確兩點： 1. 一個記錄調用一次 map()方法。 2. 相同的 key 調用一次 reduce()方法。 用戶編寫的程序分成三個部分：Mapper、Reducer 和 Driver。 1. **編寫 Mapper 類** （1）用戶自定義的 Mapper 要繼承框架提供的 Mapper 類。 （2）Mapper 的輸入數據是 KV 鍵值對的形式（KV 的類型可自定義）。 （3）對數據的處理邏輯寫在 Mapper 類中 map()方法中。 （4）Mapper 的輸出數據是 KV 鍵值對的形式（KV 的類型可自定義）。 （5）map()方法（maptask 進程）每一個<K,V>數據執行一次。 2. **編寫 Reducer 類** （1）用戶自定義的 Reducer 要繼承框架提供的 Reducer 父類。 （2）Reducer 的輸入數據類型對應 Mapper 的輸出數據類型，也是 KV。 （3）Reducer 的業務邏輯寫在 reduce()方法中。 （4）每一組相同 k 的<k,Iterator<v>>組調用一次 reduce()方法。 3. **Driver 階段** 整個程序需要編寫一個 Driver 來進行提交，將自定義 Mapper 和 Reducer 類 組合成一個 job，并提交 job 對象