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

Class DefaultMapProjectMessageTask<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,QueryResult,List<Data>>

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

All Implemented Interfaces:

SecureRequest, MessageTask, PartitionSpecificRunnable, Runnable

Direct Known Subclasses:

MapProjectionMessageTask, MapProjectionWithPredicateMessageTask

public abstract class DefaultMapProjectMessageTask<P>
extends AbstractMapQueryMessageTask<P,QueryResult,QueryResult,List<Data>>

Field Summary

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

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected void	extractAndAppendResult(Collection<QueryResult> results, QueryResult result)
protected Aggregator<?,?>	getAggregator()
protected IterationType	getIterationType()
protected Predicate	getPredicate()
protected List<Data>	reduce(Collection<QueryResult> results)

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

call, getProjection, 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, 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

DefaultMapProjectMessageTask

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

Method Detail

getIterationType

protected IterationType getIterationType()

Specified by:

getIterationType in class AbstractMapQueryMessageTask<P,QueryResult,QueryResult,List<Data>>

getAggregator

protected Aggregator<?,?> getAggregator()

Specified by:

getAggregator in class AbstractMapQueryMessageTask<P,QueryResult,QueryResult,List<Data>>

getPredicate

protected Predicate getPredicate()

Specified by:

getPredicate in class AbstractMapQueryMessageTask<P,QueryResult,QueryResult,List<Data>>

extractAndAppendResult

protected void extractAndAppendResult(Collection<QueryResult> results,
                                      QueryResult result)

Specified by:

extractAndAppendResult in class AbstractMapQueryMessageTask<P,QueryResult,QueryResult,List<Data>>

reduce

protected List<Data> reduce(Collection<QueryResult> results)

Specified by:

reduce in class AbstractMapQueryMessageTask<P,QueryResult,QueryResult,List<Data>>