public abstract class AbstractMapReduceTask<Parameters> extends AbstractMessageTask<Parameters> implements ExecutionCallback
clientEngine, clientMessage, connection, endpoint, endpointManager, logger, nodeEngine, parameters, serializationService
Constructor and Description |
---|
AbstractMapReduceTask(ClientMessage clientMessage,
Node node,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected abstract int |
getChunkSize() |
protected abstract CombinerFactory |
getCombinerFactory() |
protected abstract String |
getJobId() |
protected abstract Collection |
getKeys() |
protected abstract KeyValueSource |
getKeyValueSource() |
protected abstract Mapper |
getMapper() |
String |
getMethodName()
Used for
SecurityInterceptor
Method name which called via a distributedObject
for map.put, methodName will be 'put'
For requests which do not produced via a distributedObject should return null, for example internal client. |
Object[] |
getParameters()
Used for
SecurityInterceptor
Parameters passed to the method by a distributedObject
for map.put(key, value) parameters should be 'key' and 'value'
parameters can be in binary or object form, underlying implementation will de-serialize lazily |
protected abstract KeyPredicate |
getPredicate() |
protected abstract ReducerFactory |
getReducerFactory() |
Permission |
getRequiredPermission() |
String |
getServiceName() |
protected abstract String |
getTopologyChangedStrategy() |
void |
onFailure(Throwable t)
Called when an execution is completed with an error.
|
void |
onResponse(Object response)
Called when an execution is completed successfully.
|
protected void |
processMessage() |
decodeClientMessage, encodeResponse, getDistributedObjectName, getDistributedObjectType, getEndpoint, getPartitionId, getService, isAuthenticationMessage, run, sendClientMessage, sendClientMessage, sendClientMessage, sendResponse
public AbstractMapReduceTask(ClientMessage clientMessage, Node node, Connection connection)
protected void processMessage()
processMessage
in class AbstractMessageTask<Parameters>
protected abstract String getJobId()
protected abstract int getChunkSize()
protected abstract String getTopologyChangedStrategy()
protected abstract KeyValueSource getKeyValueSource()
protected abstract Mapper getMapper()
protected abstract CombinerFactory getCombinerFactory()
protected abstract ReducerFactory getReducerFactory()
protected abstract Collection getKeys()
protected abstract KeyPredicate getPredicate()
public void onResponse(Object response)
ExecutionCallback
onResponse
in interface ExecutionCallback
response
- the result of the successful executionpublic void onFailure(Throwable t)
ExecutionCallback
onFailure
in interface ExecutionCallback
t
- the exception that is thrownpublic String getServiceName()
getServiceName
in class AbstractMessageTask<Parameters>
public Permission getRequiredPermission()
getRequiredPermission
in interface SecureRequest
public String getMethodName()
SecureRequest
SecurityInterceptor
Method name which called via a distributedObject
for map.put, methodName will be 'put'
For requests which do not produced via a distributedObject should return null, for example internal client.getMethodName
in interface SecureRequest
getMethodName
in class AbstractMessageTask<Parameters>
public Object[] getParameters()
SecureRequest
SecurityInterceptor
Parameters passed to the method by a distributedObject
for map.put(key, value) parameters should be 'key' and 'value'
parameters can be in binary or object form, underlying implementation will de-serialize lazilygetParameters
in interface SecureRequest
getParameters
in class AbstractMessageTask<Parameters>
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.