public abstract class MapOperation extends AbstractNamedOperation implements IdentifiedDataSerializable, ServiceNamespaceAware
Modifier and Type | Field and Description |
---|---|
protected boolean |
createRecordStoreOnDemand |
protected boolean |
disableWanReplicationEvent
Used by wan-replication-service to disable wan-replication event publishing
otherwise in active-active scenarios infinite loop of event forwarding can be seen.
|
protected MapContainer |
mapContainer |
protected MapEventPublisher |
mapEventPublisher |
protected MapService |
mapService |
protected MapServiceContext |
mapServiceContext |
protected RecordStore |
recordStore |
name
GENERIC_PARTITION_ID
Constructor and Description |
---|
MapOperation() |
MapOperation(String name) |
Modifier and Type | Method and Description |
---|---|
void |
beforeRun()
The beforeRun is called before either the
Operation.run() or the Operation.call() method is called. |
protected boolean |
canThisOpGenerateWANEvent() |
protected void |
evict(Data excludedKey) |
protected CallerProvenance |
getCallerProvenance() |
int |
getFactoryId()
Returns DataSerializableFactory factory ID for this class.
|
String |
getServiceName() |
ObjectNamespace |
getServiceNamespace()
Returns the
ServiceNamespace which this object belongs to. |
long |
getThreadId() |
void |
innerBeforeRun() |
protected void |
invalidateAllKeysInNearCaches()
This method helps to add clearing Near Cache event only from one-partition which matches partitionId of the map name.
|
void |
invalidateNearCache(Data key) |
protected void |
invalidateNearCache(List<Data> keys) |
boolean |
isPostProcessing(RecordStore recordStore) |
protected void |
publishLoadAsWanUpdate(Data dataKey,
Object value) |
protected void |
publishWanRemove(Data dataKey) |
protected void |
publishWanUpdate(Data dataKey,
Object value) |
void |
setMapContainer(MapContainer mapContainer) |
void |
setMapService(MapService mapService) |
void |
setThreadId(long threadId) |
getName, readInternal, toString, writeInternal
afterRun, call, executedLocally, getCallerAddress, getCallerUuid, getCallId, getCallTimeout, getConnection, getInvocationTime, getLogger, getNodeEngine, getOperationResponseHandler, getPartitionId, getReplicaIndex, getResponse, 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
getId
readData, writeData
protected transient MapService mapService
protected transient MapContainer mapContainer
protected transient MapServiceContext mapServiceContext
protected transient MapEventPublisher mapEventPublisher
protected transient RecordStore recordStore
protected transient boolean createRecordStoreOnDemand
protected boolean disableWanReplicationEvent
public MapOperation()
public MapOperation(String name)
public void setMapService(MapService mapService)
public void setMapContainer(MapContainer mapContainer)
protected final CallerProvenance getCallerProvenance()
public void beforeRun() throws Exception
Operation
Operation.run()
or the Operation.call()
method is called.
runs before wait-supportpublic String getServiceName()
getServiceName
in class Operation
public boolean isPostProcessing(RecordStore recordStore)
public void setThreadId(long threadId)
public long getThreadId()
public final void invalidateNearCache(Data key)
protected final void invalidateAllKeysInNearCaches()
protected void evict(Data excludedKey)
public int getFactoryId()
IdentifiedDataSerializable
getFactoryId
in interface IdentifiedDataSerializable
public ObjectNamespace getServiceNamespace()
ServiceNamespaceAware
ServiceNamespace
which this object belongs to.getServiceNamespace
in interface ServiceNamespaceAware
protected final boolean canThisOpGenerateWANEvent()
true
if this operation can generate WAN event, otherwise return false
to indicate WAN event generation is not allowed for this operationprotected final void publishWanRemove(Data dataKey)
Copyright © 2022 Hazelcast, Inc.. All Rights Reserved.