yahoohadooptutorialcoderw/WordCount/Reduce.java
<reponame>jaganadhg/bitbucket_legacy_repos<filename>yahoohadooptutorialcoderw/WordCount/Reduce.javaimport java.io.IOException;
import org.apache.hadoop.io.IntWritable;
import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Reducer;

public class Reduce extends Reducer<Text, IntWritable, Text, IntWritable> {
	IntWritable result = new IntWritable();

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

}
