public class MapReplicationOperation extends Operation implements IdentifiedDataSerializable, Versioned
| Modifier and Type | Field and Description |
|---|---|
protected MapNearCacheStateHolder |
mapNearCacheStateHolder |
protected MapReplicationStateHolder |
mapReplicationStateHolder |
protected WriteBehindStateHolder |
writeBehindStateHolder |
GENERIC_PARTITION_ID| Constructor and Description |
|---|
MapReplicationOperation() |
MapReplicationOperation(PartitionContainer container,
Collection<ServiceNamespace> namespaces,
int partitionId,
int replicaIndex) |
MapReplicationOperation(PartitionContainer container,
int partitionId,
int replicaIndex) |
| Modifier and Type | Method and Description |
|---|---|
int |
getFactoryId()
Returns DataSerializableFactory factory ID for this class.
|
int |
getId()
Returns type identifier for this class.
|
String |
getServiceName() |
protected void |
readInternal(ObjectDataInput in) |
void |
run()
Runs the operation.
|
protected void |
writeInternal(ObjectDataOutput out) |
afterRun, beforeRun, call, executedLocally, getCallerAddress, getCallerUuid, getCallId, getCallTimeout, getConnection, getInvocationTime, getLogger, getNodeEngine, getOperationResponseHandler, getPartitionId, getReplicaIndex, getResponse, getService, getWaitTimeout, isUrgent, logError, onExecutionFailure, onInvocationException, onSetCallId, readData, requiresExplicitServiceName, returnsResponse, sendResponse, setCallerUuid, setNodeEngine, setOperationResponseHandler, setPartitionId, setReplicaIndex, setService, setServiceName, setValidateTarget, setWaitTimeout, toString, toString, validatesTarget, writeDataclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitreadData, writeDataprotected final MapReplicationStateHolder mapReplicationStateHolder
protected final WriteBehindStateHolder writeBehindStateHolder
protected final MapNearCacheStateHolder mapNearCacheStateHolder
public MapReplicationOperation()
public MapReplicationOperation(PartitionContainer container, int partitionId, int replicaIndex)
public MapReplicationOperation(PartitionContainer container, Collection<ServiceNamespace> namespaces, int partitionId, int replicaIndex)
public void run()
OperationOperation.run() or Operation.call() method should be implemented; not both.
Runs after wait-support, supposed to do actual operationrun in class OperationOperation.call()public String getServiceName()
getServiceName in class Operationprotected void writeInternal(ObjectDataOutput out) throws IOException
writeInternal in class OperationIOExceptionprotected void readInternal(ObjectDataInput in) throws IOException
readInternal in class OperationIOExceptionpublic int getFactoryId()
IdentifiedDataSerializablegetFactoryId in interface IdentifiedDataSerializablepublic int getId()
IdentifiedDataSerializablegetId in interface IdentifiedDataSerializableCopyright © 2020 Hazelcast, Inc.. All Rights Reserved.