com.hazelcast.map.impl.operation

Class MapOperation

java.lang.Object

com.hazelcast.spi.Operation

com.hazelcast.spi.impl.AbstractNamedOperation

com.hazelcast.map.impl.operation.MapOperation

All Implemented Interfaces:

DataSerializable, IdentifiedDataSerializable, NamedOperation, ServiceNamespaceAware

Direct Known Subclasses:

AddIndexBackupOperation, AddIndexOperation, AwaitMapFlushOperation, ClearBackupOperation, ClearNearCacheOperation, ClearOperation, ContainsValueOperation, DestroyQueryCacheOperation, EvictAllBackupOperation, EvictAllOperation, EvictBatchBackupOperation, GetAllOperation, IsKeyLoadFinishedOperation, IsPartitionLoadedOperation, KeyBasedMapOperation, KeyLoadStatusOperation, LoadAllOperation, LoadMapOperation, MadePublishableOperation, MapEventJournalSubscribeOperation, MapFetchEntriesOperation, MapFetchKeysOperation, MapFetchWithQueryOperation, MapFlushBackupOperation, MapFlushOperation, MapIsEmptyOperation, MapSizeOperation, MergeOperation, MultipleEntryBackupOperation, MultipleEntryOperation, NotifyMapFlushOperation, PartitionWideEntryBackupOperation, PartitionWideEntryOperation, PublisherCreateOperation, PutAllBackupOperation, PutAllOperation, PutFromLoadAllBackupOperation, PutFromLoadAllOperation, QueryOperation, QueryPartitionOperation, ReadAndResetAccumulatorOperation, ReadonlyKeyBasedMapOperation, RemoveFromLoadAllOperation, SetReadCursorOperation, TriggerLoadIfNeededOperation

public abstract class MapOperation
extends AbstractNamedOperation
implements IdentifiedDataSerializable, ServiceNamespaceAware

Field Summary

Fields

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

Fields inherited from class com.hazelcast.spi.impl.AbstractNamedOperation

name

Fields inherited from class com.hazelcast.spi.Operation

GENERIC_PARTITION_ID

Constructor Summary

Constructors

Constructor and Description
MapOperation()
MapOperation(String name)

Method Summary

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)

Methods inherited from class com.hazelcast.spi.impl.AbstractNamedOperation

getName, readInternal, toString, writeInternal

Methods inherited from class com.hazelcast.spi.Operation

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.hazelcast.nio.serialization.IdentifiedDataSerializable

getId

Methods inherited from interface com.hazelcast.nio.serialization.DataSerializable

readData, writeData

Field Detail

mapService

protected transient MapService mapService

mapContainer

protected transient MapContainer mapContainer

mapServiceContext

protected transient MapServiceContext mapServiceContext

mapEventPublisher

protected transient MapEventPublisher mapEventPublisher

recordStore

protected transient RecordStore recordStore

createRecordStoreOnDemand

protected transient boolean createRecordStoreOnDemand

disableWanReplicationEvent

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.

Constructor Detail

MapOperation

public MapOperation()

MapOperation

public MapOperation(String name)

Method Detail

setMapService

public void setMapService(MapService mapService)

setMapContainer

public void setMapContainer(MapContainer mapContainer)

getCallerProvenance

protected final CallerProvenance getCallerProvenance()

beforeRun

public void beforeRun()
               throws Exception

Description copied from class: Operation

The beforeRun is called before either the Operation.run() or the Operation.call() method is called. runs before wait-support

Overrides:

beforeRun in class Operation

Throws:

Exception

innerBeforeRun

public void innerBeforeRun()
                    throws Exception

Throws:

Exception

getServiceName

public String getServiceName()

Overrides:

getServiceName in class Operation

isPostProcessing

public boolean isPostProcessing(RecordStore recordStore)

setThreadId

public void setThreadId(long threadId)

getThreadId

public long getThreadId()

invalidateNearCache

protected final void invalidateNearCache(List<Data> keys)

invalidateNearCache

public final void invalidateNearCache(Data key)

invalidateAllKeysInNearCaches

protected final void invalidateAllKeysInNearCaches()

This method helps to add clearing Near Cache event only from one-partition which matches partitionId of the map name.

evict

protected void evict(Data excludedKey)

getFactoryId

public int getFactoryId()

Description copied from interface: IdentifiedDataSerializable

Returns DataSerializableFactory factory ID for this class.

Specified by:

getFactoryId in interface IdentifiedDataSerializable

Returns:

factory ID

getServiceNamespace

public ObjectNamespace getServiceNamespace()

Description copied from interface: ServiceNamespaceAware

Returns the ServiceNamespace which this object belongs to.

Specified by:

getServiceNamespace in interface ServiceNamespaceAware

Returns:

service namespace

canThisOpGenerateWANEvent

protected final boolean canThisOpGenerateWANEvent()

Returns:

true if this operation can generate WAN event, otherwise return false to indicate WAN event generation is not allowed for this operation

publishWanUpdate

protected final void publishWanUpdate(Data dataKey,
                                      Object value)

publishLoadAsWanUpdate

protected final void publishLoadAsWanUpdate(Data dataKey,
                                            Object value)

publishWanRemove

protected final void publishWanRemove(Data dataKey)