MapReduce求和數字作業

Question

假設給出了一個數字列表，說明如何實現一個MapReduce作業來獲得這些數字的總和。

由於

Answer 1

這是字面上上的減速機的Hadoop documentation給出的示例。

public class IntSumReducer extends Reducer { 
    private IntWritable result = new IntWritable(); 

    public void reduce(Key key, Iterable values, 
         Context context) throws IOException { 
     int sum = 0; 
     for (IntWritable val : values) { 
      sum += val.get(); 
     } 
     result.set(sum); 
     context.collect(key, result); 
    } 
}