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

Class AbstractMapQueryMessageTask<P,QueryResult extends Result,AccumulatedResults,ReducedResult>

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,AccumulatedResults,ReducedResult>

All Implemented Interfaces:

SecureRequest, MessageTask, PartitionSpecificRunnable, Runnable

Direct Known Subclasses:

DefaultMapAggregateMessageTask, DefaultMapProjectMessageTask, DefaultMapQueryMessageTask

public abstract class AbstractMapQueryMessageTask<P,QueryResult extends Result,AccumulatedResults,ReducedResult>
extends AbstractCallableMessageTask<P>

Field Summary

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

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected Object	call()
protected abstract void	extractAndAppendResult(Collection<AccumulatedResults> results, QueryResult queryResult)
protected abstract Aggregator<?,?>	getAggregator()
protected abstract IterationType	getIterationType()
protected abstract Predicate	getPredicate()
protected abstract Projection<?,?>	getProjection()
Permission	getRequiredPermission()
String	getServiceName()
protected abstract ReducedResult	reduce(Collection<AccumulatedResults> results)

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

processMessage

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

decodeClientMessage, doRun, encodeResponse, getDistributedObjectName, getDistributedObjectType, getMemberBuildInfo, getMethodName, getParameters, getPartitionId, getService, handleProcessingFailure, 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

AbstractMapQueryMessageTask

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

Method Detail

getServiceName

public final String getServiceName()

Specified by:

getServiceName in class AbstractMessageTask<P>

getRequiredPermission

public Permission getRequiredPermission()

getPredicate

protected abstract Predicate getPredicate()

getAggregator

protected abstract Aggregator<?,?> getAggregator()

getProjection

protected abstract Projection<?,?> getProjection()

extractAndAppendResult

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

reduce

protected abstract ReducedResult reduce(Collection<AccumulatedResults> results)

getIterationType

protected abstract IterationType getIterationType()

call

protected final Object call()
                     throws Exception

Specified by:

call in class AbstractCallableMessageTask<P>

Throws:

Exception