Operation (Hazelcast Root 3.7 API)

java.lang.Object
- com.hazelcast.spi.Operation

All Implemented Interfaces:

DataSerializable

Direct Known Subclasses:

AbstractOperation, Backup, CallableTaskOperation, CancellationOperation, CheckReplicaVersion, CollectionOperation, GetMapConfigOperation, MemberCallableTaskOperation, MultiMapOperation, PartitionIteratingOperation, QueueOperation, ReplicaSyncRequest, ReplicaSyncResponse, ReplicaSyncRetryResponse, ReplicationOperation, ScriptExecutorOperation, ShutdownRequestOperation, ShutdownResponseOperation, ThreadDumpOperation, UpdateManagementCenterUrlOperation, UpdateMapConfigOperation
```
public abstract class Operation
extends Object
implements DataSerializable
```
An operation could be compared to a Runnable. It contains logic that is going to be executed; this logic will be placed in the run() method.

Field Summary

Fields
Modifier and Type Field and Description

static int GENERIC_PARTITION_ID
Marks an Operation as non partition specific.

Fields
Modifier and Type	Field and Description
`static int`	`GENERIC_PARTITION_ID` Marks an `Operation` as non partition specific.

Constructor Summary

Constructors
Constructor and Description

Operation()

Constructors
Constructor and Description
`Operation()`

Method Summary

Methods
Modifier and Type	Method and Description
`void`	`afterRun()`
`void`	`beforeRun()`
`Address`	`getCallerAddress()`
`String`	`getCallerUuid()`
`long`	`getCallId()` Gets the callId of this Operation.
`long`	`getCallTimeout()` Gets the call timeout in milliseconds.
`Connection`	`getConnection()`
`long`	`getInvocationTime()` Gets the time in milliseconds since this invocation started.
`protected ILogger`	`getLogger()`
`NodeEngine`	`getNodeEngine()`
`OperationResponseHandler`	`getOperationResponseHandler()` Gets the OperationResponseHandler tied to this Operation.
`int`	`getPartitionId()` Returns the id of the partition that this Operation will be executed upon.
`int`	`getReplicaIndex()`
`Object`	`getResponse()`
`<T> T`	`getService()`
`String`	`getServiceName()`
`long`	`getWaitTimeout()`
`boolean`	`isUrgent()`
`void`	`logError(Throwable e)` Logs `Exception`/`Error` thrown during operation execution.
`void`	`onExecutionFailure(Throwable e)` Called when an `Exception`/`Error` is thrown during operation execution.
`ExceptionAction`	`onInvocationException(Throwable throwable)` Called when an `Exception`/`Error` is thrown during an invocation.
`protected void`	`onSetCallId()` This method is called every time a new `callId` is set to the operation.
`void`	`readData(ObjectDataInput in)` Reads fields from the input stream
`protected void`	`readInternal(ObjectDataInput in)`
`boolean`	`returnsResponse()`
`abstract void`	`run()`
`void`	`sendResponse(Object value)`
`Operation`	`setCallerUuid(String callerUuid)`
`Operation`	`setNodeEngine(NodeEngine nodeEngine)`
`Operation`	`setOperationResponseHandler(OperationResponseHandler responseHandler)` Sets the OperationResponseHandler.
`Operation`	`setPartitionId(int partitionId)` Sets the partition id.
`Operation`	`setReplicaIndex(int replicaIndex)`
`Operation`	`setService(Object service)`
`Operation`	`setServiceName(String serviceName)`
`Operation`	`setValidateTarget(boolean validateTarget)`
`void`	`setWaitTimeout(long timeout)`
`String`	`toString()`
`protected void`	`toString(StringBuilder sb)` A template method allows for additional information to be passed into the `toString()` method.
`boolean`	`validatesTarget()`
`void`	`writeData(ObjectDataOutput out)` Writes object fields to output stream
`protected void`	`writeInternal(ObjectDataOutput out)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

- Field Detail
  - GENERIC_PARTITION_ID
```
public static final int GENERIC_PARTITION_ID
```
    Marks an Operation as non partition specific.
    
    See Also:
    Constant Field Values
- Constructor Detail
  - Operation
```
public Operation()
```
- Method Detail
  - isUrgent
```
public boolean isUrgent()
```
  - beforeRun
```
public void beforeRun()
               throws Exception
```
    Throws:
    
    Exception
  - run
```
public abstract void run()
                  throws Exception
```
    Throws:
    
    Exception
  - afterRun
```
public void afterRun()
              throws Exception
```
    Throws:
    
    Exception
  - returnsResponse
```
public boolean returnsResponse()
```
  - getResponse
```
public Object getResponse()
```
  - getServiceName
```
public String getServiceName()
```
  - setServiceName
```
public final Operation setServiceName(String serviceName)
```
  - getPartitionId
```
public final int getPartitionId()
```
    Returns the id of the partition that this Operation will be executed upon. If the partitionId is equal or larger than 0, it means that it is tied to a specific partition: for example, a map.get('foo'). If it is smaller than 0, than it means that it isn't bound to a particular partition. The partitionId should never be equal or larger than the total number of partitions. For example, if there are 271 partitions, the maximum partitionId is 270. The partitionId is used by the OperationService to figure out which member owns a specific partition, and to send the operation to that member.
    
    Returns:
    the id of the partition.
    See Also:
    setPartitionId(int)
  - setPartitionId
```
public final Operation setPartitionId(int partitionId)
```
    Sets the partition id.
    
    Parameters:
    partitionId - the id of the partition.
    
    Returns:
    the updated Operation.
    See Also:
    getPartitionId()
  - getReplicaIndex
```
public final int getReplicaIndex()
```
  - setReplicaIndex
```
public final Operation setReplicaIndex(int replicaIndex)
```
  - getCallId
```
public final long getCallId()
```
    Gets the callId of this Operation. The callId is used to associate the invocation of an Operation on a remote system, with the response from the execution of that operation.
    
    Returns:
    the callId.
  - onSetCallId
```
protected void onSetCallId()
```
    This method is called every time a new callId is set to the operation. A new callId is set to an operation before initial invocation and before every invocation retry.
    By default this is a no-op method. Operation implementations which are willing to get notified on callId changes can override this method. New callId can be accessed by calling getCallId().
    For example an operation can distinguish the first invocation and invocation retries by keeping the initial callId.
  - validatesTarget
```
public boolean validatesTarget()
```
  - setValidateTarget
```
public final Operation setValidateTarget(boolean validateTarget)
```
  - getNodeEngine
```
public final NodeEngine getNodeEngine()
```
  - setNodeEngine
```
public final Operation setNodeEngine(NodeEngine nodeEngine)
```
  - getService
```
public final <T> T getService()
```
  - setService
```
public final Operation setService(Object service)
```
  - getCallerAddress
```
public final Address getCallerAddress()
```
  - getConnection
```
public final Connection getConnection()
```
  - getOperationResponseHandler
```
public final OperationResponseHandler getOperationResponseHandler()
```
    Gets the OperationResponseHandler tied to this Operation. The returned value can be null.
    
    Returns:
    the OperationResponseHandler
  - setOperationResponseHandler
```
public final Operation setOperationResponseHandler(OperationResponseHandler responseHandler)
```
    Sets the OperationResponseHandler. Value is allowed to be null.
    
    Parameters:
    responseHandler - the OperationResponseHandler to set.
    
    Returns:
    this instance.
  - sendResponse
```
public final void sendResponse(Object value)
```
  - getInvocationTime
```
public final long getInvocationTime()
```
    Gets the time in milliseconds since this invocation started. For more information, see ClusterClock.getClusterTime().
    
    Returns:
    the time of the invocation start.
  - getCallTimeout
```
public final long getCallTimeout()
```
    Gets the call timeout in milliseconds. For example, if a call should start execution within 60 seconds otherwise it should be aborted, then the call-timeout is 60000 milliseconds. Once an operation starts execution and runs for a long period (e.g. 5 minutes with an IExecutorService execute operation), then the call timeout isn't relevant any longer. For more information about the default value, see GroupProperty.OPERATION_CALL_TIMEOUT_MILLIS
    
    Returns:
    the call timeout in milliseconds.
    See Also:
    setCallTimeout(long), OperationAccessor.setCallTimeout(Operation, long)
  - getWaitTimeout
```
public final long getWaitTimeout()
```
  - setWaitTimeout
```
public final void setWaitTimeout(long timeout)
```
  - onInvocationException
```
public ExceptionAction onInvocationException(Throwable throwable)
```
    Called when an Exception/Error is thrown during an invocation. Invocation process will continue, retry or fail according to returned ExceptionAction result.
    This method is called on caller side of the invocation.
    
    Parameters:
    throwable - Exception/Error thrown during invocation
    
    Returns:
    ExceptionAction
  - getCallerUuid
```
public String getCallerUuid()
```
  - setCallerUuid
```
public Operation setCallerUuid(String callerUuid)
```
  - getLogger
```
protected final ILogger getLogger()
```
  - onExecutionFailure
```
public void onExecutionFailure(Throwable e)
```
    Called when an Exception/Error is thrown during operation execution.
    By default this method does nothing. Operation implementations can override this behaviour due to their needs.
    This method is called on node & thread that's executing the operation.
    
    Parameters:
    e - Exception/Error thrown during operation execution
  - logError
```
public void logError(Throwable e)
```
    Logs Exception/Error thrown during operation execution. Operation implementations can override this behaviour due to their needs.
    This method is called on node & thread that's executing the operation.
    
    Parameters:
    e - Exception/Error thrown during operation execution
  - writeData
```
public final void writeData(ObjectDataOutput out)
                     throws IOException
```
    Description copied from interface: DataSerializable
    
    Writes object fields to output stream
    
    Specified by:
    
    writeData in interface DataSerializable
    
    Parameters:
    out - output
    
    Throws:
    
    IOException
  - readData
```
public final void readData(ObjectDataInput in)
                    throws IOException
```
    Description copied from interface: DataSerializable
    
    Reads fields from the input stream
    
    Specified by:
    
    readData in interface DataSerializable
    
    Parameters:
    in - input
    
    Throws:
    
    IOException
  - writeInternal
```
protected void writeInternal(ObjectDataOutput out)
                      throws IOException
```
    Throws:
    
    IOException
  - readInternal
```
protected void readInternal(ObjectDataInput in)
                     throws IOException
```
    Throws:
    
    IOException
  - toString
```
protected void toString(StringBuilder sb)
```
    A template method allows for additional information to be passed into the toString() method. So an Operation subclass can override this method and add additional debugging content. The default implementation does nothing so one is not forced to provide an empty implementation. It is a good practice always to call the super.toString(stringBuffer) when implementing this method to make sure that the super class can inject content if needed.
    
    Parameters:
    sb - the StringBuilder to add the debug info to.
  - toString
```
public String toString()
```
    Overrides:
    
    toString in class Object

Class Operation

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

GENERIC_PARTITION_ID

Constructor Detail

Operation

Method Detail

isUrgent

beforeRun

run

afterRun

returnsResponse

getResponse

getServiceName

setServiceName

getPartitionId

setPartitionId

getReplicaIndex

setReplicaIndex

getCallId

onSetCallId

validatesTarget

setValidateTarget

getNodeEngine

setNodeEngine

getService

setService

getCallerAddress

getConnection

getOperationResponseHandler

setOperationResponseHandler

sendResponse

getInvocationTime

getCallTimeout

getWaitTimeout

setWaitTimeout

onInvocationException

getCallerUuid

setCallerUuid

getLogger

onExecutionFailure

logError

writeData

readData

writeInternal

readInternal

toString

toString