com.hazelcast.map.impl.query

Interface AccumulationExecutor

All Known Implementing Classes:

CallerRunsAccumulationExecutor, ParallelAccumulationExecutor

public interface AccumulationExecutor

Executes the accumulation phase of the Aggregator. All entries are accumulates by the result aggregator returned in the AggregationResult

Method Summary

Modifier and Type	Method and Description
AggregationResult	execute(Aggregator aggregator, Collection<QueryableEntry> entries, Collection<Integer> partitionIds)

Method Detail

execute

AggregationResult execute(Aggregator aggregator,
                          Collection<QueryableEntry> entries,
                          Collection<Integer> partitionIds)

Parameters:

aggregator - Instance of aggregator using which the entries should be accumulated. It will not be modified.

entries - Entries to be accumulated

partitionIds - Ids of the partitions where the entries reside.

Returns:

AggregationResult encompassing the result aggregator.