public abstract class AbstractMapQueryMessageTask<P> extends AbstractCallableMessageTask<P>
clientEngine, clientMessage, connection, endpoint, endpointManager, logger, nodeEngine, parameters, serializationService
Modifier | Constructor and Description |
---|---|
protected |
AbstractMapQueryMessageTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected Object |
call() |
protected abstract IterationType |
getIterationType() |
protected abstract Predicate |
getPredicate() |
Permission |
getRequiredPermission() |
String |
getServiceName() |
protected abstract Object |
reduce(Collection<QueryResultRow> result) |
processMessage
decodeClientMessage, encodeResponse, getDistributedObjectName, getDistributedObjectType, getEndpoint, getMethodName, getParameters, getPartitionId, getService, isAuthenticationMessage, run, sendClientMessage, sendClientMessage, sendClientMessage, sendResponse
protected AbstractMapQueryMessageTask(ClientMessage clientMessage, Node node, Connection connection)
public final String getServiceName()
getServiceName
in class AbstractMessageTask<P>
public Permission getRequiredPermission()
protected abstract Predicate getPredicate()
protected abstract IterationType getIterationType()
protected abstract Object reduce(Collection<QueryResultRow> result)
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.