public class ReplaceOperation extends BasePutOperation implements MutatingOperation
eventType, oldValuedataKey, dataValue, threadIdcreateRecordStoreOnDemand, disposeDeferredBlocks, mapContainer, mapEventPublisher, mapService, mapServiceContext, recordStorenameGENERIC_PARTITION_ID| Constructor and Description |
|---|
ReplaceOperation() |
ReplaceOperation(String name,
Data dataKey,
Data value) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
afterRunInternal() |
int |
getClassId()
Returns type identifier for this class.
|
Object |
getResponse()
Called if and only if
Operation.returnsResponse() returned true,
shortly after Operation.run() returns. |
protected void |
runInternal() |
boolean |
shouldBackup()
Checks if a backup needs to be made.
|
getAsyncBackupCount, getBackupOperation, getSyncBackupCount, newBackupOperation, onWaitExpiregetWaitKey, shouldWaitgetKey, getThreadId, getValue, readInternal, setThreadId, writeInternalafterRun, beforeRun, disableWanReplicationEvent, evict, getCallerProvenance, getFactoryId, getServiceName, getServiceNamespace, innerBeforeRun, invalidateAllKeysInNearCaches, invalidateNearCache, invalidateNearCache, isPostProcessing, logError, onExecutionFailure, publishLoadAsWanUpdate, publishWanRemove, publishWanUpdate, run, setMapContainer, setMapService, wbqCapacityCountergetName, toStringcall, executedLocally, getCallerAddress, getCallerUuid, getCallId, getCallTimeout, getClientCallId, getConnection, getInvocationTime, getLogger, getNodeEngine, getOperationResponseHandler, getPartitionId, getReplicaIndex, getService, getWaitTimeout, isUrgent, onInvocationException, onSetCallId, readData, requiresExplicitServiceName, returnsResponse, sendResponse, setCallerUuid, setClientCallId, setNodeEngine, setOperationResponseHandler, setPartitionId, setReplicaIndex, setService, setServiceName, setValidateTarget, setWaitTimeout, toString, validatesTarget, writeDataclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetPartitionIdgetWaitTimeoutreadData, writeDataprotected void runInternal()
runInternal in class MapOperationpublic boolean shouldBackup()
BackupAwareOperationIf a call has not made any change, e.g. an AtomicLong increment with 0, no backup needs to be made.
shouldBackup in interface BackupAwareOperationshouldBackup in class BasePutOperationprotected void afterRunInternal()
afterRunInternal in class BasePutOperationpublic Object getResponse()
OperationOperation.returnsResponse() returned true,
shortly after Operation.run() returns.getResponse in class Operationpublic int getClassId()
IdentifiedDataSerializablegetClassId in interface IdentifiedDataSerializableCopyright © 2019 Hazelcast, Inc.. All rights reserved.