org.infinispan.distexec.mapreduce

Interface Collator<KOut,VOut,R>

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

Methods

Modifier and Type	Method and Description
R	collate(java.util.Map<KOut,VOut> reducedResults) Collates all reduced results and returns R to invoker of distributed task.

Method Detail

collate

R collate(java.util.Map<KOut,VOut> reducedResults)

Collates all reduced results and returns R to invoker of distributed task.

Returns:

final result of distributed task computation