com.hazelcast.client.impl.protocol.task.map

Class DefaultMapAggregateMessageTask<P>

java.lang.Object

com.hazelcast.client.impl.protocol.task.AbstractMessageTask<P>

com.hazelcast.client.impl.protocol.task.AbstractCallableMessageTask<P>

com.hazelcast.client.impl.protocol.task.map.AbstractMapQueryMessageTask<P,AggregationResult,AggregationResult,Object>

com.hazelcast.client.impl.protocol.task.map.DefaultMapAggregateMessageTask<P>

All Implemented Interfaces:

SecureRequest, MessageTask, PartitionSpecificRunnable, Runnable

Direct Known Subclasses:

MapAggregateMessageTask, MapAggregateWithPredicateMessageTask

public abstract class DefaultMapAggregateMessageTask<P>
extends AbstractMapQueryMessageTask<P,AggregationResult,AggregationResult,Object>

Field Summary

Fields inherited from class com.hazelcast.client.impl.protocol.task.AbstractMessageTask

clientEngine, clientMessage, connection, endpoint, endpointManager, logger, nodeEngine, parameters, serializationService

Constructor Summary

Constructors

Constructor and Description
DefaultMapAggregateMessageTask(ClientMessage clientMessage, Node node, Connection connection)

Method Summary

Modifier and Type	Method and Description
protected void	extractAndAppendResult(Collection<AggregationResult> results, AggregationResult aggregationResult)
protected IterationType	getIterationType()
protected Predicate	getPredicate()
protected Projection<?,?>	getProjection()
protected Object	reduce(Collection<AggregationResult> results)

Methods inherited from class com.hazelcast.client.impl.protocol.task.map.AbstractMapQueryMessageTask

call, getAggregator, getRequiredPermission, getServiceName

Methods inherited from class com.hazelcast.client.impl.protocol.task.AbstractCallableMessageTask

processMessage

Methods inherited from class com.hazelcast.client.impl.protocol.task.AbstractMessageTask

decodeClientMessage, encodeResponse, getClientVersion, getDistributedObjectName, getDistributedObjectType, getEndpoint, getMemberBuildInfo, getMethodName, getParameters, getPartitionId, getService, handleProcessingFailure, isAuthenticationMessage, run, sendClientMessage, sendClientMessage, sendClientMessage, sendResponse

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultMapAggregateMessageTask

public DefaultMapAggregateMessageTask(ClientMessage clientMessage,
                                      Node node,
                                      Connection connection)

Method Detail

getIterationType

protected IterationType getIterationType()

Specified by:

getIterationType in class AbstractMapQueryMessageTask<P,AggregationResult,AggregationResult,Object>

getProjection

protected Projection<?,?> getProjection()

Specified by:

getProjection in class AbstractMapQueryMessageTask<P,AggregationResult,AggregationResult,Object>

getPredicate

protected Predicate getPredicate()

Specified by:

getPredicate in class AbstractMapQueryMessageTask<P,AggregationResult,AggregationResult,Object>

extractAndAppendResult

protected void extractAndAppendResult(Collection<AggregationResult> results,
                                      AggregationResult aggregationResult)

Specified by:

extractAndAppendResult in class AbstractMapQueryMessageTask<P,AggregationResult,AggregationResult,Object>

reduce

protected Object reduce(Collection<AggregationResult> results)

Specified by:

reduce in class AbstractMapQueryMessageTask<P,AggregationResult,AggregationResult,Object>