example hadoop reducer

reduce.java

package com.mycompany.emr;

import java.io.IOException;
import java.util.*;

import org.apache.hadoop.io.*;
import org.apache.hadoop.mapreduce.*;

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