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

Class DefaultMapQueryMessageTask<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,QueryResult,QueryResultRow,Object>

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

All Implemented Interfaces:

SecureRequest, MessageTask, PartitionSpecificRunnable, Runnable

Direct Known Subclasses:

MapEntriesWithPagingPredicateMessageTask, MapEntriesWithPredicateMessageTask, MapEntrySetMessageTask, MapKeySetMessageTask, MapKeySetWithPagingPredicateMessageTask, MapKeySetWithPredicateMessageTask, MapValuesMessageTask, MapValuesWithPagingPredicateMessageTask, MapValuesWithPredicateMessageTask

public abstract class DefaultMapQueryMessageTask<P>
extends AbstractMapQueryMessageTask<P,QueryResult,QueryResultRow,Object>

Field Summary

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

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

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	DefaultMapQueryMessageTask(ClientMessage clientMessage, Node node, Connection connection)

Method Summary

Modifier and Type	Method and Description
protected void	extractAndAppendResult(Collection<QueryResultRow> results, QueryResult queryResult)
protected Aggregator<?,?>	getAggregator()
protected Projection<?,?>	getProjection()

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

call, getIterationType, getPredicate, getRequiredPermission, getServiceName, reduce

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, findSendConnection, getClientVersion, getDistributedObjectName, getDistributedObjectType, getEndpoint, 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

DefaultMapQueryMessageTask

protected DefaultMapQueryMessageTask(ClientMessage clientMessage,
                                     Node node,
                                     Connection connection)

Method Detail

getAggregator

protected Aggregator<?,?> getAggregator()

Specified by:

getAggregator in class AbstractMapQueryMessageTask<P,QueryResult,QueryResultRow,Object>

getProjection

protected Projection<?,?> getProjection()

Specified by:

getProjection in class AbstractMapQueryMessageTask<P,QueryResult,QueryResultRow,Object>

extractAndAppendResult

protected void extractAndAppendResult(Collection<QueryResultRow> results,
                                      QueryResult queryResult)

Specified by:

extractAndAppendResult in class AbstractMapQueryMessageTask<P,QueryResult,QueryResultRow,Object>