cgl.imr.base.impl
Class MapOutputCollectorImpl

java.lang.Object
  extended by cgl.imr.base.impl.MapOutputCollectorImpl
All Implemented Interfaces:
MapOutputCollector

public class MapOutputCollectorImpl
extends Object
implements MapOutputCollector

Collector for Map outputs.


Constructor Summary
MapOutputCollectorImpl(ReducerSelector reducerSelector)
           
 
Method Summary
 void collect(Key key, Value val)
          Collect pairs produced by the map task.
 List<ReduceInput> getReduceInputs()
          Generate and returns the reduce inputs after grouping the pairs using some algorithm such as hashing.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

MapOutputCollectorImpl

public MapOutputCollectorImpl(ReducerSelector reducerSelector)
Method Detail

collect

public void collect(Key key,
                    Value val)
Description copied from interface: MapOutputCollector
Collect pairs produced by the map task.

Specified by:
collect in interface MapOutputCollector
Parameters:
key - A Key generated by the map task.
val - Value associated with the above Key.

getReduceInputs

public List<ReduceInput> getReduceInputs()
Description copied from interface: MapOutputCollector
Generate and returns the reduce inputs after grouping the pairs using some algorithm such as hashing.

Specified by:
getReduceInputs in interface MapOutputCollector
Returns:
List of reduce inputs.


For comments and suggestions please send e-mail to