com.hazelcast.map.impl.operation

Class MapOperation

java.lang.Object

com.hazelcast.spi.impl.operationservice.Operation

com.hazelcast.spi.impl.operationservice.AbstractNamedOperation

com.hazelcast.map.impl.operation.MapOperation

All Implemented Interfaces:

ServiceNamespaceAware, DataSerializable, IdentifiedDataSerializable, NamedOperation

Direct Known Subclasses:

AddIndexBackupOperation, AddIndexOperation, AwaitMapFlushOperation, ClearBackupOperation, 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, PutAllBackupOperation, PutAllOperation, PutBackupOperation, PutFromLoadAllBackupOperation, PutFromLoadAllOperation, 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	disposeDeferredBlocks
protected MapContainer	mapContainer
protected MapEventPublisher	mapEventPublisher
protected MapService	mapService
protected MapServiceContext	mapServiceContext
protected RecordStore	recordStore

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

name

Fields inherited from class com.hazelcast.spi.impl.operationservice.Operation

GENERIC_PARTITION_ID

Constructor Summary

Constructors

Constructor and Description
MapOperation()
MapOperation(String name)

Method Summary

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.
protected void	afterRunInternal()
void	beforeRun() The beforeRun is called before either the Operation.run() or the Operation.call() method is called.
protected boolean	disableWanReplicationEvent()
protected void	evict(Data justAddedKey)
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()
protected 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)
void	logError(Throwable e) Logs Exception/Error thrown during operation execution.
void	onExecutionFailure(Throwable e) Called when an Exception/Error is thrown during operation execution.
protected void	publishLoadAsWanUpdate(Data dataKey, Object value)
protected void	publishWanRemove(Data dataKey)
protected void	publishWanUpdate(Data dataKey, Object value)
void	run() Runs the operation.
protected void	runInternal()
void	setMapContainer(MapContainer mapContainer)
void	setMapService(MapService mapService)
void	setThreadId(long threadId)
protected TxnReservedCapacityCounter	wbqCapacityCounter()

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

getName, readInternal, toString, writeInternal

Methods inherited from class com.hazelcast.spi.impl.operationservice.Operation

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

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

getClassId

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

readData, writeData

Field Detail

mapService

protected transient MapService mapService

recordStore

protected transient RecordStore recordStore

mapContainer

protected transient MapContainer mapContainer

mapServiceContext

protected transient MapServiceContext mapServiceContext

mapEventPublisher

protected transient MapEventPublisher mapEventPublisher

createRecordStoreOnDemand

protected transient boolean createRecordStoreOnDemand

disposeDeferredBlocks

protected transient boolean disposeDeferredBlocks

Constructor Detail

MapOperation

public MapOperation()

MapOperation

public MapOperation(String name)

Method Detail

beforeRun

public final 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

protected void innerBeforeRun()
                       throws Exception

Throws:

Exception

run

public final void run()

Description copied from class: Operation

Runs the operation. Either the Operation.run() or Operation.call() method should be implemented; not both. Runs after wait-support, supposed to do actual operation

Overrides:

run in class Operation

See Also:

Operation.call()

runInternal

protected void runInternal()

afterRun

public final void afterRun()
                    throws Exception

Description copied from class: Operation

Is executed called after Operation.run() or Operation.call() method completes normally and the operation is not blocked, see CallStatus.WAIT. Runs after backups, before wait-notify.

Overrides:

afterRun in class Operation

Throws:

Exception

afterRunInternal

protected void afterRunInternal()

getCallerProvenance

protected final CallerProvenance getCallerProvenance()

onExecutionFailure

public void onExecutionFailure(Throwable e)

Description copied from class: Operation

Called when an Exception/Error is thrown during operation execution.

By default this method does nothing. Operation implementations can override this behaviour according to their needs.

This method is called on node & thread that's executing the operation.

Overrides:

onExecutionFailure in class Operation

Parameters:

e - Exception/Error thrown during operation execution

logError

public void logError(Throwable e)

Description copied from class: Operation

Logs Exception/Error thrown during operation execution. Operation implementations can override this behaviour according to their needs.

This method is called on node & thread that's executing the operation.

Overrides:

logError in class Operation

Parameters:

e - Exception/Error thrown during operation execution

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 final void evict(Data justAddedKey)

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

setMapService

public void setMapService(MapService mapService)

setMapContainer

public void setMapContainer(MapContainer mapContainer)

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)

disableWanReplicationEvent

protected boolean disableWanReplicationEvent()

wbqCapacityCounter

protected final TxnReservedCapacityCounter wbqCapacityCounter()