2012-09-24 2 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); 
    } 
} 
관련 문제