public class MyReducer extends Reducer { @Override public void reduce(Text key, Interable values, Context context) throws IOException, InterruptedException { Text outputKey = new Text(); Text outputValue = new Text(); for (Text value: values) { // ... } context.write(outputKey, outputValue); } }