MapMultipleValuesReducer.java 文件源码

@Override
public void reduce(Text key, Iterable<MapWritable> values, Context context)
        throws IOException, InterruptedException {

    for (MapWritable value : values) {

        int i = ((IntWritable) value.get(new IntWritable(1))).get();
        float f = ((FloatWritable) value.get(new IntWritable(2))).get();
        String s = ((Text) value.get(new IntWritable(3))).toString();

        mw.put(new IntWritable(1), new IntWritable(i * 2));
        mw.put(new IntWritable(2), new FloatWritable(f * 2));
        mw.put(new IntWritable(3), new Text(s));

        context.write(key, mw);
    }
}