2012-09-24 75 views

回答

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); 
    } 
}