在編寫 mapreduce 程序時，需要考慮的幾個方面： 1. 輸入數據接口：InputFormat 默認使用的實現類是：TextInputFormat TextInputFormat 的功能邏輯是：一次讀一行文本，然后將該行的起始偏移量作為 key，行內容作為 value 返回。 用戶還可以自定義 InputFormat。 2. 邏輯處理接口：Mapper 用戶根據業務需求實現其中三個方法：map()，setup()，cleanup () 。 3. Partitioner 分區 有默認實現 HashPartitioner，邏輯是根據 key 的哈希值和 numReduces 來返回一個分區號；key.hashCode()&Integer.MAXVALUE % numReduces。 如果業務上有特別的需求，可以自定義分區。 4. Combiner 合并 Combiner 合并可以提高程序執行效率，減少 io 傳輸。但是使用時必須不能影響原有的業務處理結果。 5. 邏輯處理接口：Reducer 用戶根據業務需求實現其中三個方法：reduce()，setup()，cleanup () 6. 輸出數據接口：OutputFormat 默認實現類是 TextOutputFormat，功能邏輯是：將每一個 KV 對向目標文本文件中輸出為一行。 用戶還可以自定義 OutputFormat。