org.infinispan.distexec.mapreduce
Interface Collator<KOut,VOut,R>
- All Known Implementing Classes:
- WordCountCollator
public interface Collator<KOut,VOut,R>
Collator collates 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.execute(Collator)
,
MapReduceTask.executeAsynchronously(Collator)
,
Reducer
Method Summary |
R |
collate(Map<KOut,VOut> reducedResults)
Collates all reduced results and returns R to invoker of distributed task. |
collate
R collate(Map<KOut,VOut> reducedResults)
- Collates all reduced results and returns R to invoker of distributed task.
- Returns:
- final result of distributed task computation
Copyright © 2012 JBoss, a division of Red Hat. All Rights Reserved.