org.apache.hadoop.mapred
Class Task.OldCombinerRunner<K,V>

java.lang.Object
  extended by org.apache.hadoop.mapred.Task.CombinerRunner<K,V>
      extended by org.apache.hadoop.mapred.Task.OldCombinerRunner<K,V>
Enclosing class:
Task

protected static class Task.OldCombinerRunner<K,V>
extends Task.CombinerRunner<K,V>


Field Summary
 
Fields inherited from class org.apache.hadoop.mapred.Task.CombinerRunner
inputCounter, job, reporter
 
Constructor Summary
protected Task.OldCombinerRunner(Class<? extends Reducer<K,V,K,V>> cls, JobConf conf, Counters.Counter inputCounter, Task.TaskReporter reporter)
           
 
Method Summary
protected  void combine(RawKeyValueIterator kvIter, OutputCollector<K,V> combineCollector)
          Run the combiner over a set of inputs.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

Task.OldCombinerRunner

protected Task.OldCombinerRunner(Class<? extends Reducer<K,V,K,V>> cls,
                                 JobConf conf,
                                 Counters.Counter inputCounter,
                                 Task.TaskReporter reporter)
Method Detail

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 input
combineCollector - the output collector
Throws:
IOException


Copyright © 2009 The Apache Software Foundation