com.hazelcast.mapreduce
Interface Collator<ValueIn,ValueOut>

Type Parameters:

ValueIn - value type of the resulting values

ValueOut - type for the collated result

@Beta
public interface Collator<ValueIn,ValueOut>

This interface can be implemented to define a Collator which is executed after calculation of the MapReduce algorithm on remote cluster nodes but before returning the final result.
Collator can for example be used to sum up a final value.

Since:

3.2

Method Summary

ValueOut

collate(Iterable<ValueIn> values) This method is called with the mapped and possibly reduced values from the MapReduce algorithm.

Method Detail

collate

ValueOut collate(Iterable<ValueIn> values)

This method is called with the mapped and possibly reduced values from the MapReduce algorithm.

Parameters:

values - The mapped and possibly reduced results

Returns:

The collated result