public static class CLSlidingWindowPwsim.MyReducer extends MapReduceBase implements Reducer<PairOfInts,IntWritable,PairOfInts,IntWritable>
Constructor and Description |
---|
CLSlidingWindowPwsim.MyReducer() |
Modifier and Type | Method and Description |
---|---|
void |
reduce(PairOfInts key,
Iterator<IntWritable> val,
OutputCollector<PairOfInts,IntWritable> output,
Reporter reporter) |
close, configure
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
configure
public void reduce(PairOfInts key, Iterator<IntWritable> val, OutputCollector<PairOfInts,IntWritable> output, Reporter reporter) throws IOException
reduce
in interface Reducer<PairOfInts,IntWritable,PairOfInts,IntWritable>
IOException