com.hazelcast.map.impl.operation

Class HDMapOperation

java.lang.Object

com.hazelcast.spi.Operation

com.hazelcast.spi.impl.AbstractNamedOperation

com.hazelcast.map.impl.operation.MapOperation

com.hazelcast.map.impl.operation.HDMapOperation

All Implemented Interfaces:

com.hazelcast.nio.serialization.DataSerializable, com.hazelcast.nio.serialization.IdentifiedDataSerializable, com.hazelcast.spi.NamedOperation, com.hazelcast.spi.ServiceNamespaceAware

Direct Known Subclasses:

HDClearBackupOperation, HDClearOperation, HDContainsValueOperation, HDEvictAllBackupOperation, HDEvictAllOperation, HDGetAllOperation, HDKeyBasedMapOperation, HDLoadAllOperation, HDLoadMapOperation, HDMapFetchEntriesOperation, HDMapFetchKeysOperation, HDMapFetchWithQueryOperation, HDMapFlushBackupOperation, HDMapFlushOperation, HDMapSizeOperation, HDMergeOperation, HDMultipleEntryBackupOperation, HDMultipleEntryOperation, HDPartitionWideEntryBackupOperation, HDPartitionWideEntryOperation, HDPutAllBackupOperation, HDPutAllOperation, HDPutFromLoadAllBackupOperation, HDPutFromLoadAllOperation, HDQueryPartitionOperation

public abstract class HDMapOperation
extends com.hazelcast.map.impl.operation.MapOperation

This class should be extended if operation runs by partition operation threads. Includes retry logic when a map operation fails to put an entry into IMap due to a NativeOutOfMemoryError.

If an IMap is evictable, naturally expected thing is, all put operations should be successful. Because if there is no more space, operation can be able to evict some entries and can put the new ones.

This abstract class forces the evictable record-stores on this partition thread to be evicted in the event of a NativeOutOfMemoryError.

Used when InMemoryFormat is NATIVE.

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_FORCED_EVICTION_RETRY_COUNT
static com.hazelcast.spi.properties.HazelcastProperty	FORCED_EVICTION_RETRY_COUNT
static String	PROP_FORCED_EVICTION_RETRY_COUNT

Fields inherited from class com.hazelcast.map.impl.operation.MapOperation

createRecordStoreOnDemand, disableWanReplicationEvent, mapContainer, mapEventPublisher, mapService, mapServiceContext, 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
HDMapOperation()
HDMapOperation(String name)

Method Summary

Modifier and Type	Method and Description
void	afterRun()
protected void	disposeDeferredBlocks()
protected void	evict(com.hazelcast.nio.serialization.Data justAddedKey)
int	getFactoryId()
protected int	getRetryCount()
long	getThreadId()
void	innerBeforeRun()
void	logError(Throwable e)
void	onExecutionFailure(Throwable e)
void	run()
protected abstract void	runInternal()
void	setThreadId(long threadId)

Methods inherited from class com.hazelcast.map.impl.operation.MapOperation

beforeRun, canThisOpGenerateWANEvent, getCallerProvenance, getServiceName, getServiceNamespace, invalidateAllKeysInNearCaches, invalidateNearCache, invalidateNearCache, isPostProcessing, publishLoadAsWanUpdate, publishWanRemove, publishWanUpdate, setMapContainer, setMapService

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

getName, readInternal, toString, writeInternal

Methods inherited from class com.hazelcast.spi.Operation

call, executedLocally, getCallerAddress, getCallerUuid, getCallId, getCallTimeout, getConnection, getInvocationTime, getLogger, getNodeEngine, getOperationResponseHandler, getPartitionId, getReplicaIndex, getResponse, getService, getWaitTimeout, isUrgent, onInvocationException, onSetCallId, readData, requiresExplicitServiceName, returnsResponse, 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

PROP_FORCED_EVICTION_RETRY_COUNT

public static final String PROP_FORCED_EVICTION_RETRY_COUNT

See Also:

Constant Field Values

DEFAULT_FORCED_EVICTION_RETRY_COUNT

public static final int DEFAULT_FORCED_EVICTION_RETRY_COUNT

See Also:

Constant Field Values

FORCED_EVICTION_RETRY_COUNT

public static final com.hazelcast.spi.properties.HazelcastProperty FORCED_EVICTION_RETRY_COUNT

Constructor Detail

HDMapOperation

public HDMapOperation()

HDMapOperation

public HDMapOperation(String name)

Method Detail

getFactoryId

public final int getFactoryId()

Specified by:

getFactoryId in interface com.hazelcast.nio.serialization.IdentifiedDataSerializable

Overrides:

getFactoryId in class com.hazelcast.map.impl.operation.MapOperation

getThreadId

public long getThreadId()

Overrides:

getThreadId in class com.hazelcast.map.impl.operation.MapOperation

setThreadId

public void setThreadId(long threadId)

Overrides:

setThreadId in class com.hazelcast.map.impl.operation.MapOperation

innerBeforeRun

public void innerBeforeRun()
                    throws Exception

Overrides:

innerBeforeRun in class com.hazelcast.map.impl.operation.MapOperation

Throws:

Exception

run

public final void run()

Overrides:

run in class com.hazelcast.spi.Operation

getRetryCount

protected int getRetryCount()

afterRun

public void afterRun()
              throws Exception

Overrides:

afterRun in class com.hazelcast.spi.Operation

Throws:

Exception

onExecutionFailure

public void onExecutionFailure(Throwable e)

Overrides:

onExecutionFailure in class com.hazelcast.spi.Operation

logError

public void logError(Throwable e)

Overrides:

logError in class com.hazelcast.spi.Operation

evict

protected final void evict(com.hazelcast.nio.serialization.Data justAddedKey)

Overrides:

evict in class com.hazelcast.map.impl.operation.MapOperation

runInternal

protected abstract void runInternal()

disposeDeferredBlocks

protected final void disposeDeferredBlocks()