org.apache.hadoop.mapred
Class Task.OldCombinerRunner<K,V>
java.lang.Object
org.apache.hadoop.mapred.Task.CombinerRunner<K,V>
org.apache.hadoop.mapred.Task.OldCombinerRunner<K,V>
- Enclosing class:
- Task
protected static class Task.OldCombinerRunner<K,V>
- extends Task.CombinerRunner<K,V>
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Task.OldCombinerRunner
protected Task.OldCombinerRunner(Class<? extends Reducer<K,V,K,V>> cls,
JobConf conf,
Counters.Counter inputCounter,
Task.TaskReporter reporter)
combine
protected void combine(RawKeyValueIterator kvIter,
OutputCollector<K,V> combineCollector)
throws IOException
- Description copied from class:
Task.CombinerRunner
- Run the combiner over a set of inputs.
- Parameters:
kvIter
- the key/value pairs to use as inputcombineCollector
- the output collector
- Throws:
IOException
Copyright © 2009 The Apache Software Foundation