2014-03-25 61 views

回答

1

簡單地圖任務是Mapper的一個實例。 Mapper和Reducer是mapreduce作業中的方法。

當我們運行mapreduce作業時,產生的地圖任務數量取決於輸入中的數字塊(塊的數量取決於輸入分割)。但是,reduce任務的數量可以在mapreduce驅動程序代碼中指定。它可以通過在作業配置對象中設置屬性mapred.reduce.tasks來指定,也可以使用org.apache.hadoop.mapreduce.Job#setNumReduceTasks(int reducerCount);方法。

在舊的JobConf API setNumMapTasks()方法在那裏。但是在新的API org.apache.hadoop.mapreduce.Job中刪除了setNumMapTasks()方法,映射器數量的內涵應根據輸入拆分進行計算。

+0

可以使用mapred.map.tasks和setNumMapTasks來指定mappers的數量嗎? – user3458106

+0

我也修改了答案 – sachin

+0

,我如何檢查爲特定工作運行的mappers/redurs任務的實際數量? – user3458106

相關問題