org.infinispan.distexec.mapreduce
Interface Collator<R>


public interface Collator<R>

Collator coordinates results from Reducers executed on Infinispan cluster and assembles a final result returned to an invoker of MapReduceTask.

Since:
5.0
Author:
Manik Surtani, Vladimir Blagojevic
See Also:
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

collate

R collate()
Collates all results added so far and returns result R to invoker of distributed task.

Returns:
final result of distributed task computation

reducedResultReceived

void reducedResultReceived(Address remoteNode,
                           R remoteResult)
Invoked by runtime every time reduced result R is received from executed Reducer on remote nodes.

Parameters:
remoteNode - address of the node where reduce phase occurred
remoteResult - the result R of reduce phase


Copyright © 2011 JBoss, a division of Red Hat. All Rights Reserved.