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

java.lang.Object
  extended by org.apache.hadoop.mapred.Task.CombineOutputCollector<K,V>
All Implemented Interfaces:
OutputCollector<K,V>
Enclosing class:
Task

protected static class Task.CombineOutputCollector<K,V>
extends Object
implements OutputCollector<K,V>

OutputCollector for the combiner.


Constructor Summary
Task.CombineOutputCollector(Counters.Counter outCounter, Progressable progressable, Configuration conf)
           
 
Method Summary
 void collect(K key, V value)
          Adds a key/value pair to the output.
 void setWriter(IFile.Writer<K,V> writer)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

Task.CombineOutputCollector

public Task.CombineOutputCollector(Counters.Counter outCounter,
                                   Progressable progressable,
                                   Configuration conf)
Method Detail

setWriter

public void setWriter(IFile.Writer<K,V> writer)

collect

public void collect(K key,
                    V value)
             throws IOException
Description copied from interface: OutputCollector
Adds a key/value pair to the output.

Specified by:
collect in interface OutputCollector<K,V>
Parameters:
key - the key to collect.
value - to value to collect.
Throws:
IOException


Copyright © 2009 The Apache Software Foundation