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, mapServiceContext
name
CALL_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, clearNearCache, invalidateNearCache, invalidateNearCache, setMapContainer, setMapService
getName
getResponse
getCallerAddress, 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, writeData
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getPartitionId
getName
protected Data dataKey
protected long threadId
protected Data dataValue
protected long ttl
protected transient RecordStore recordStore
public void innerBeforeRun() throws Exception
innerBeforeRun
in class MapOperation
Exception
public String getServiceName()
getServiceName
in class MapOperation
public final Data getKey()
public final long getThreadId()
getThreadId
in class MapOperation
public final void setThreadId(long threadId)
setThreadId
in class MapOperation
public final Data getValue()
public final long getTtl()
public void afterRun() throws Exception
afterRun
in class MapOperation
Exception
public boolean returnsResponse()
returnsResponse
in class AbstractOperation
protected void evict()
protected void writeInternal(ObjectDataOutput out) throws IOException
writeInternal
in class AbstractNamedOperation
IOException
protected void readInternal(ObjectDataInput in) throws IOException
readInternal
in class AbstractNamedOperation
IOException
protected void toString(StringBuilder sb)
Operation
Operation.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 AbstractNamedOperation
sb
- the StringBuilder to add the debug info to.Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.