edu.umd.cloud9.demo
Class DemoWordCount.MyReducer
java.lang.Object
org.apache.hadoop.mapred.MapReduceBase
edu.umd.cloud9.demo.DemoWordCount.MyReducer
- All Implemented Interfaces:
- Closeable, JobConfigurable, Reducer<Text,IntWritable,Text,IntWritable>
- Enclosing class:
- DemoWordCount
public static class DemoWordCount.MyReducer
- extends MapReduceBase
- implements Reducer<Text,IntWritable,Text,IntWritable>
DemoWordCount.MyReducer
public DemoWordCount.MyReducer()
reduce
public void reduce(Text key,
Iterator<IntWritable> values,
OutputCollector<Text,IntWritable> output,
Reporter reporter)
throws IOException
- Specified by:
reduce in interface Reducer<Text,IntWritable,Text,IntWritable>
- Throws:
IOException