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, configureequals, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitconfigurepublic void reduce(PairOfInts key, Iterator<IntWritable> val, OutputCollector<PairOfInts,IntWritable> output, Reporter reporter) throws IOException
reduce in interface Reducer<PairOfInts,IntWritable,PairOfInts,IntWritable>IOException