public abstract class BasePutOperation extends LockAwareOperation implements BackupAwareOperation
Modifier and Type | Field and Description |
---|---|
protected EntryEventType |
eventType |
protected Object |
oldValue |
dataKey, dataValue, threadId
createRecordStoreOnDemand, disposeDeferredBlocks, mapContainer, mapEventPublisher, mapService, mapServiceContext, recordStore
name
GENERIC_PARTITION_ID
Constructor and Description |
---|
BasePutOperation() |
BasePutOperation(String name,
Data dataKey,
Data value) |
Modifier and Type | Method and Description |
---|---|
protected void |
afterRunInternal() |
int |
getAsyncBackupCount()
The asynchronous backup count.
|
Operation |
getBackupOperation()
Creates the
BackupOperation responsible for making the backup. |
int |
getSyncBackupCount()
The synchronous backup count.
|
protected PutBackupOperation |
newBackupOperation(RecordInfo replicationInfo) |
void |
onWaitExpire() |
boolean |
shouldBackup()
Checks if a backup needs to be made.
|
getWaitKey, shouldWait
getKey, getThreadId, getValue, readInternal, setThreadId, writeInternal
afterRun, beforeRun, disableWanReplicationEvent, evict, getCallerProvenance, getFactoryId, getServiceName, getServiceNamespace, innerBeforeRun, invalidateAllKeysInNearCaches, invalidateNearCache, invalidateNearCache, isPostProcessing, logError, onExecutionFailure, publishLoadAsWanUpdate, publishWanRemove, publishWanUpdate, run, runInternal, setMapContainer, setMapService, wbqCapacityCounter
getName, toString
call, executedLocally, getCallerAddress, getCallerUuid, getCallId, getCallTimeout, getClientCallId, getConnection, getInvocationTime, getLogger, getNodeEngine, getOperationResponseHandler, getPartitionId, getReplicaIndex, getResponse, getService, getWaitTimeout, isUrgent, onInvocationException, onSetCallId, readData, requiresExplicitServiceName, returnsResponse, sendResponse, setCallerUuid, setClientCallId, setNodeEngine, setOperationResponseHandler, setPartitionId, setReplicaIndex, setService, setServiceName, setValidateTarget, setWaitTimeout, toString, validatesTarget, writeData
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getPartitionId
getWaitTimeout
getClassId
readData, writeData
protected transient Object oldValue
protected transient EntryEventType eventType
protected void afterRunInternal()
afterRunInternal
in class MapOperation
public boolean shouldBackup()
BackupAwareOperation
If a call has not made any change, e.g. an AtomicLong increment with 0, no backup needs to be made.
shouldBackup
in interface BackupAwareOperation
public Operation getBackupOperation()
BackupAwareOperation
BackupOperation
responsible for making the backup.getBackupOperation
in interface BackupAwareOperation
BackupOperation
responsible for making the backup.protected PutBackupOperation newBackupOperation(RecordInfo replicationInfo)
public final int getAsyncBackupCount()
BackupAwareOperation
getAsyncBackupCount
in interface BackupAwareOperation
public final int getSyncBackupCount()
BackupAwareOperation
getSyncBackupCount
in interface BackupAwareOperation
public void onWaitExpire()
onWaitExpire
in interface BlockingOperation
onWaitExpire
in class LockAwareOperation
Copyright © 2019 Hazelcast, Inc.. All rights reserved.