public abstract class KeyBasedMapOperation extends MapOperation implements PartitionAwareOperation, NamedOperation
| Modifier and Type | Field and Description |
|---|---|
protected Data |
dataKey |
protected Data |
dataValue |
protected RecordStore |
recordStore |
protected long |
threadId |
protected long |
ttl |
mapContainer, mapService, mapServiceContextnameCALL_ID_LOCAL_SKIPPED, GENERIC_PARTITION_ID| Modifier | Constructor and Description |
|---|---|
|
KeyBasedMapOperation() |
|
KeyBasedMapOperation(String name,
Data dataKey) |
protected |
KeyBasedMapOperation(String name,
Data dataKey,
Data dataValue) |
protected |
KeyBasedMapOperation(String name,
Data dataKey,
Data dataValue,
long ttl) |
protected |
KeyBasedMapOperation(String name,
Data dataKey,
long ttl) |
| Modifier and Type | Method and Description |
|---|---|
void |
afterRun() |
protected void |
evict() |
Data |
getKey() |
String |
getServiceName() |
long |
getThreadId() |
long |
getTtl() |
Data |
getValue() |
void |
innerBeforeRun() |
protected void |
readInternal(ObjectDataInput in) |
boolean |
returnsResponse() |
void |
setThreadId(long threadId) |
protected void |
toString(StringBuilder sb)
A template method allows for additional information to be passed into the
Operation.toString() method. |
protected void |
writeInternal(ObjectDataOutput out) |
beforeRun, clearLocalNearCache, invalidateNearCache, invalidateNearCache, isPostProcessing, setMapContainer, setMapServicegetNamegetResponsegetCallerAddress, getCallerUuid, getCallId, getCallTimeout, getConnection, getInvocationTime, getLogger, getNodeEngine, getOperationResponseHandler, getPartitionId, getReplicaIndex, getResponseHandler, getService, getWaitTimeout, isUrgent, logError, onException, onExecutionFailure, onInvocationException, onSetCallId, readData, run, sendResponse, setCallerUuid, setNodeEngine, setOperationResponseHandler, setPartitionId, setReplicaIndex, setResponseHandler, setService, setServiceName, setValidateTarget, setWaitTimeout, toString, validatesTarget, writeDataclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetPartitionIdgetNameprotected Data dataKey
protected long threadId
protected Data dataValue
protected long ttl
protected transient RecordStore recordStore
public void innerBeforeRun()
throws Exception
innerBeforeRun in class MapOperationExceptionpublic String getServiceName()
getServiceName in class MapOperationpublic final Data getKey()
public final long getThreadId()
getThreadId in class MapOperationpublic final void setThreadId(long threadId)
setThreadId in class MapOperationpublic final Data getValue()
public final long getTtl()
public void afterRun()
throws Exception
afterRun in class MapOperationExceptionpublic boolean returnsResponse()
returnsResponse in class AbstractOperationprotected void evict()
protected void writeInternal(ObjectDataOutput out) throws IOException
writeInternal in class AbstractNamedOperationIOExceptionprotected void readInternal(ObjectDataInput in) throws IOException
readInternal in class AbstractNamedOperationIOExceptionprotected void toString(StringBuilder sb)
OperationOperation.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.toString in class AbstractNamedOperationsb - the StringBuilder to add the debug info to.Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.