protected static class Task.NewCombinerRunner<K,V> extends Task.CombinerRunner<K,V>
inputCounter, job, reporter
Modifier and Type | Method and Description |
---|---|
void |
combine(RawKeyValueIterator iterator,
OutputCollector<K,V> collector)
Run the combiner over a set of inputs.
|
create
public void combine(RawKeyValueIterator iterator, OutputCollector<K,V> collector) throws java.io.IOException, java.lang.InterruptedException, java.lang.ClassNotFoundException
Task.CombinerRunner
combine
in class Task.CombinerRunner<K,V>
iterator
- the key/value pairs to use as inputcollector
- the output collectorjava.io.IOException
java.lang.InterruptedException
java.lang.ClassNotFoundException
Copyright © 2009 The Apache Software Foundation