public abstract class BaseRemoveOperation extends LockAwareOperation implements BackupAwareOperation, MutatingOperation
Modifier and Type | Field and Description |
---|---|
protected Data |
dataOldValue |
dataKey, dataValue, maxIdle, threadId, ttl
createRecordStoreOnDemand, disableWanReplicationEvent, mapContainer, mapEventPublisher, mapService, mapServiceContext, recordStore
name
GENERIC_PARTITION_ID
Constructor and Description |
---|
BaseRemoveOperation() |
BaseRemoveOperation(String name,
Data dataKey) |
BaseRemoveOperation(String name,
Data dataKey,
boolean disableWanReplicationEvent) |
Modifier and Type | Method and Description |
---|---|
void |
afterRun()
Is executed called after
Operation.run() or Operation.call() method completes normally and the operation is not
blocked, see CallStatus.WAIT . |
int |
getAsyncBackupCount()
The asynchronous backup count.
|
Operation |
getBackupOperation()
Creates the
BackupOperation responsible for making the backup. |
Object |
getResponse()
Called if and only if
Operation.returnsResponse() returned true ,
shortly after Operation.run() returns. |
int |
getSyncBackupCount()
The synchronous backup count.
|
void |
onWaitExpire() |
protected void |
readInternal(ObjectDataInput in) |
boolean |
shouldBackup()
Checks if a backup needs to be made.
|
protected void |
writeInternal(ObjectDataOutput out) |
getWaitKey, shouldWait
getKey, getThreadId, getTtl, getValue, setThreadId
beforeRun, canThisOpGenerateWANEvent, evict, getCallerProvenance, getFactoryId, getServiceName, getServiceNamespace, innerBeforeRun, invalidateAllKeysInNearCaches, invalidateNearCache, invalidateNearCache, isPostProcessing, publishLoadAsWanUpdate, publishWanRemove, publishWanUpdate, setMapContainer, setMapService
getName, toString
call, executedLocally, getCallerAddress, getCallerUuid, getCallId, getCallTimeout, getConnection, getInvocationTime, getLogger, getNodeEngine, getOperationResponseHandler, getPartitionId, getReplicaIndex, getService, getWaitTimeout, isUrgent, logError, onExecutionFailure, onInvocationException, onSetCallId, readData, requiresExplicitServiceName, returnsResponse, run, sendResponse, setCallerUuid, setNodeEngine, setOperationResponseHandler, setPartitionId, setReplicaIndex, setService, setServiceName, setValidateTarget, setWaitTimeout, toString, validatesTarget, writeData
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getPartitionId
getWaitTimeout
getId
readData, writeData
protected transient Data dataOldValue
public BaseRemoveOperation(String name, Data dataKey, boolean disableWanReplicationEvent)
public BaseRemoveOperation()
public void afterRun()
Operation
Operation.run()
or Operation.call()
method completes normally and the operation is not
blocked, see CallStatus.WAIT
.
Runs after backups, before wait-notify.public Object getResponse()
Operation
Operation.returnsResponse()
returned true
,
shortly after Operation.run()
returns.getResponse
in class Operation
public Operation getBackupOperation()
BackupAwareOperation
BackupOperation
responsible for making the backup.getBackupOperation
in interface BackupAwareOperation
BackupOperation
responsible for making the backup.public int getAsyncBackupCount()
BackupAwareOperation
getAsyncBackupCount
in interface BackupAwareOperation
public int getSyncBackupCount()
BackupAwareOperation
getSyncBackupCount
in interface BackupAwareOperation
public boolean shouldBackup()
BackupAwareOperation
shouldBackup
in interface BackupAwareOperation
public void onWaitExpire()
onWaitExpire
in interface BlockingOperation
onWaitExpire
in class LockAwareOperation
protected void writeInternal(ObjectDataOutput out) throws IOException
writeInternal
in class KeyBasedMapOperation
IOException
protected void readInternal(ObjectDataInput in) throws IOException
readInternal
in class KeyBasedMapOperation
IOException
Copyright © 2018 Hazelcast, Inc.. All Rights Reserved.