|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface Collator<R>
Collator coordinates results from Reducers executed on Infinispan cluster and assembles a final result returned to an invoker of MapReduceTask.
MapReduceTask
,
Reducer
Method Summary | |
---|---|
R |
collate()
Collates all results added so far and returns result R to invoker of distributed task. |
void |
reducedResultReceived(Address remoteNode,
R remoteResult)
Invoked by runtime every time reduced result R is received from executed Reducer on remote nodes. |
Method Detail |
---|
R collate()
void reducedResultReceived(Address remoteNode, R remoteResult)
remoteNode
- address of the node where reduce phase occurredremoteResult
- the result R of reduce phase
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |