com.hazelcast.map.impl.query

Class AggregationResultProcessor

java.lang.Object

com.hazelcast.map.impl.query.AggregationResultProcessor

All Implemented Interfaces:

ResultProcessor<AggregationResult>

public class AggregationResultProcessor
extends Object
implements ResultProcessor<AggregationResult>

Responsible for populating AggregationResults

Constructor Summary

Constructors

Constructor and Description
AggregationResultProcessor(AccumulationExecutor accumulationExecutor, SerializationService serializationService)

Method Summary

Modifier and Type	Method and Description
AggregationResult	populateResult(Query query, long resultLimit) Populate an empty result for the given query type.
AggregationResult	populateResult(Query query, long resultLimit, Collection<QueryableEntry> entries, Collection<Integer> partitionIds) Populate an non-empty result for the given query type.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AggregationResultProcessor

public AggregationResultProcessor(AccumulationExecutor accumulationExecutor,
                                  SerializationService serializationService)

Method Detail

populateResult

public AggregationResult populateResult(Query query,
                                        long resultLimit,
                                        Collection<QueryableEntry> entries,
                                        Collection<Integer> partitionIds)

Description copied from interface: ResultProcessor

Populate an non-empty result for the given query type.

Specified by:

populateResult in interface ResultProcessor<AggregationResult>

Parameters:

query - given query

resultLimit - given resultLimit

entries - entries to add to the result to

partitionIds - partitionIds where the given entries reside

Returns:

Result of a concrete type.

populateResult

public AggregationResult populateResult(Query query,
                                        long resultLimit)

Description copied from interface: ResultProcessor

Populate an empty result for the given query type.

Specified by:

populateResult in interface ResultProcessor<AggregationResult>

Parameters:

query - given query

resultLimit - given resultLimit (ignored)

Returns:

Result of a concrete type.