T
- the CRDT typepublic abstract class AbstractCRDTReplicationOperation<T extends IdentifiedDataSerializable> extends Operation implements IdentifiedDataSerializable, com.hazelcast.internal.partition.MigrationCycleOperation
IdentifiedDataSerializable
values. In the case of CRDT
replication, this will be a map from map name to CRDT state.
Each concrete implementation of this class should be responsible for a
single CRDT type and the replication map should only contain CRDT
states for this CRDT type.GENERIC_PARTITION_ID
Modifier | Constructor and Description |
---|---|
protected |
AbstractCRDTReplicationOperation() |
|
AbstractCRDTReplicationOperation(Map<String,T> replicationData)
Constructs the replication operation.
|
Modifier and Type | Method and Description |
---|---|
void |
afterRun() |
int |
getFactoryId()
Returns DataSerializableFactory factory ID for this class.
|
protected void |
readInternal(ObjectDataInput in) |
void |
run() |
protected void |
writeInternal(ObjectDataOutput out) |
beforeRun, call, executedLocally, getCallerAddress, getCallerUuid, getCallId, getCallTimeout, getConnection, getInvocationTime, getLogger, getNodeEngine, getOperationResponseHandler, getPartitionId, getReplicaIndex, getResponse, getService, getServiceName, getWaitTimeout, isUrgent, logError, onExecutionFailure, onInvocationException, onSetCallId, readData, returnsResponse, sendResponse, setCallerUuid, setNodeEngine, setOperationResponseHandler, setPartitionId, setReplicaIndex, setService, setServiceName, setValidateTarget, setWaitTimeout, toString, toString, validatesTarget, writeData
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getId
readData, writeData
public void afterRun() throws Exception
public int getFactoryId()
IdentifiedDataSerializable
getFactoryId
in interface IdentifiedDataSerializable
protected void writeInternal(ObjectDataOutput out) throws IOException
writeInternal
in class Operation
IOException
protected void readInternal(ObjectDataInput in) throws IOException
readInternal
in class Operation
IOException
Copyright © 2018 Hazelcast, Inc.. All rights reserved.