com.hazelcast.map.impl.operation

Class EnterpriseMapReplicationOperation

java.lang.Object

com.hazelcast.spi.Operation

com.hazelcast.map.impl.operation.MapReplicationOperation

com.hazelcast.map.impl.operation.EnterpriseMapReplicationOperation

All Implemented Interfaces:

com.hazelcast.nio.serialization.DataSerializable, com.hazelcast.nio.serialization.IdentifiedDataSerializable, com.hazelcast.nio.serialization.impl.Versioned

public class EnterpriseMapReplicationOperation
extends com.hazelcast.map.impl.operation.MapReplicationOperation

Replicates all IMap-states of this partition to a replica partition. Additionally deals with Hi-Density backed IMap specific cases by handling NativeOutOfMemoryError.

Field Summary

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

mapNearCacheStateHolder, mapReplicationStateHolder, writeBehindStateHolder

Fields inherited from class com.hazelcast.spi.Operation

GENERIC_PARTITION_ID

Constructor Summary

Constructors

Constructor and Description
EnterpriseMapReplicationOperation()
EnterpriseMapReplicationOperation(com.hazelcast.map.impl.PartitionContainer container, Collection<com.hazelcast.spi.ServiceNamespace> namespaces, int partitionId, int replicaIndex)
EnterpriseMapReplicationOperation(com.hazelcast.map.impl.PartitionContainer container, int partitionId, int replicaIndex)

Method Summary

Modifier and Type	Method and Description
void	afterRun()
int	getFactoryId()
int	getId()
void	onExecutionFailure(Throwable e)
void	run()

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

getServiceName, readInternal, writeInternal

Methods inherited from class com.hazelcast.spi.Operation

beforeRun, call, executedLocally, getCallerAddress, getCallerUuid, getCallId, getCallTimeout, getConnection, getInvocationTime, getLogger, getNodeEngine, getOperationResponseHandler, getPartitionId, getReplicaIndex, getResponse, getService, getWaitTimeout, isUrgent, logError, onInvocationException, onSetCallId, readData, requiresExplicitServiceName, returnsResponse, sendResponse, setCallerUuid, setNodeEngine, setOperationResponseHandler, setPartitionId, setReplicaIndex, setService, setServiceName, setValidateTarget, setWaitTimeout, toString, 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.DataSerializable

readData, writeData

Constructor Detail

EnterpriseMapReplicationOperation

public EnterpriseMapReplicationOperation()

EnterpriseMapReplicationOperation

public EnterpriseMapReplicationOperation(com.hazelcast.map.impl.PartitionContainer container,
                                         int partitionId,
                                         int replicaIndex)

EnterpriseMapReplicationOperation

public EnterpriseMapReplicationOperation(com.hazelcast.map.impl.PartitionContainer container,
                                         Collection<com.hazelcast.spi.ServiceNamespace> namespaces,
                                         int partitionId,
                                         int replicaIndex)

Method Detail

run

public void run()

Overrides:

run in class com.hazelcast.map.impl.operation.MapReplicationOperation

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

getFactoryId

public int getFactoryId()

Specified by:

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

Overrides:

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

getId

public int getId()

Specified by:

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

Overrides:

getId in class com.hazelcast.map.impl.operation.MapReplicationOperation