cgl.imr.base
Interface ReduceOutputCollector

All Known Implementing Classes:
ReduceOutputCollectorImpl

public interface ReduceOutputCollector

Interface for collecting outputs of the Reduce tasks. Any implementation should support collecting pairs and produce a CombineInput.


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.
 

Method Detail

collect

void collect(Key key,
             Value val)
Collect the output of the Reduce task.

Parameters:
key - Key generated by the Reduce task.
val - Value associated with the above Key

getCombineInput

CombineInput getCombineInput()
Returns a combine input by grouping the Reduce outputs.

Returns:
combine input.


For comments and suggestions please send e-mail to