public class CallerRunsAccumulationExecutor extends Object implements AccumulationExecutor
AccumulationExecutor
that runs the accumulation in the calling thread in a sequential fashion.Constructor and Description |
---|
CallerRunsAccumulationExecutor(SerializationService serializationService) |
Modifier and Type | Method and Description |
---|---|
AggregationResult |
execute(Aggregator aggregator,
Collection<QueryableEntry> entries,
Collection<Integer> partitionIds) |
public CallerRunsAccumulationExecutor(SerializationService serializationService)
public AggregationResult execute(Aggregator aggregator, Collection<QueryableEntry> entries, Collection<Integer> partitionIds)
execute
in interface AccumulationExecutor
aggregator
- Instance of aggregator using which the entries should be accumulated (it will not be modified)entries
- Entries to be accumulatedpartitionIds
- IDs of the partitions where the entries resideCopyright © 2019 Hazelcast, Inc.. All Rights Reserved.