cgl.imr.base.impl
Class ReduceOutputCollectorImpl

java.lang.Object
  extended by cgl.imr.base.impl.ReduceOutputCollectorImpl
All Implemented Interfaces:
ReduceOutputCollector

public class ReduceOutputCollectorImpl
extends Object
implements ReduceOutputCollector

Collect the output of a Reduce task that need to be passed to the CombineTask.


Constructor Summary
ReduceOutputCollectorImpl(String combineSink)
           
 
Method Summary
 void collect(Key key, Value val)
          Collect the output of the Reduce task.
 CombineInput getCombineInput()
          Returns a combine input by grouping the Reduce outputs.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ReduceOutputCollectorImpl

public ReduceOutputCollectorImpl(String combineSink)
Method Detail

collect

public void collect(Key key,
                    Value val)
Description copied from interface: ReduceOutputCollector
Collect the output of the Reduce task.

Specified by:
collect in interface ReduceOutputCollector
Parameters:
key - Key generated by the Reduce task.
val - Value associated with the above Key

getCombineInput

public CombineInput getCombineInput()
Description copied from interface: ReduceOutputCollector
Returns a combine input by grouping the Reduce outputs.

Specified by:
getCombineInput in interface ReduceOutputCollector
Returns:
combine input.


For comments and suggestions please send e-mail to