Class PartialUpdateReplicationPacketData
java.lang.Object
com.gigaspaces.internal.cluster.node.impl.packets.data.operations.AbstractReplicationPacketSingleEntryData
com.gigaspaces.internal.cluster.node.impl.packets.data.operations.SingleReplicationPacketData
com.gigaspaces.internal.cluster.node.impl.packets.data.operations.UpdateReplicationPacketData
com.gigaspaces.internal.cluster.node.impl.packets.data.operations.PartialUpdateReplicationPacketData
- All Implemented Interfaces:
IExecutableReplicationPacketData<IReplicationPacketEntryData>, IReplicationPacketData<IReplicationPacketEntryData>, IReplicationPacketEntryData, IReplicationTransactionalPacketEntryData, ISwapExternalizable, SmartExternalizable, Externalizable, Serializable, Cloneable, Iterable<IReplicationPacketEntryData>, Collection<IReplicationPacketEntryData>
- See Also:
-
Nested Class Summary
Nested classes/interfaces inherited from class AbstractReplicationPacketSingleEntryData
AbstractReplicationPacketSingleEntryData.SingleEntryIterator, AbstractReplicationPacketSingleEntryData.SingleFilterIterable -
Field Summary
Fields inherited from class UpdateReplicationPacketData
_currentEntryData, _flags, _previousEntryData -
Constructor Summary
ConstructorsConstructorDescriptionPartialUpdateReplicationPacketData(IEntryPacket entry, boolean fromGateway, boolean overrideVersion, IEntryData previousEntryData, long expertaionTime, IEntryData currentEntryData) -
Method Summary
Modifier and TypeMethodDescriptionvoidbatchExecuteTransactional(IReplicationInBatchContext context, ITransactionalBatchExecutionCallback executionCallback) clone()booleanprotected voidvoidexecute(IReplicationInContext context, IReplicationInFacade inReplicationHandler, ReplicationPacketDataMediator dataMediator) voidexecuteTransactional(IReplicationInContext context, ITransactionalExecutionCallback transactionExecutionCallback, Transaction transaction, boolean twoPhaseCommit) protected voidprotected voidtoString()Methods inherited from class UpdateReplicationPacketData
beforeDelayedReplication, filterIfNotPresentInReplicaState, getExpirationTime, getFilterObjectType, getFilterReplicationOpType, getFlags, getMainEntryData, getOperationType, getPreviousEntryData, getPreviousEntryPacket, getSecondaryEntryData, isOverrideVersion, isSerializeFullContent, readExternal, readFromSwap, readPreviousEntryData, serializeFullContent, writeExternal, writePreviousEntryData, writeToSwapMethods inherited from class SingleReplicationPacketData
cloneWithEntryPacket, getEntryPacket, getOperationId, getOrderCode, getTypeDescriptor, getTypeName, getUid, isTransient, toFilterEntry, updateEntryPacketTimeToLiveIfNeededMethods inherited from class AbstractReplicationPacketSingleEntryData
add, addAll, clear, contains, containsAll, createEmptyMultipleEntryData, deserializeEntryData, getBlobstoreBulkId, getCustomContent, getMainTypeName, getMultipleOperationType, getRecoveryFilteringId, getSingleEntryData, getWeight, isEmpty, isFromGateway, isMultiParticipantData, isPartOfBlobstoreBulk, isSingleEntryData, iterator, remove, removeAll, requiresRecoveryDuplicationProtection, requiresRecoveryFiltering, retainAll, serializeEntryData, setBlobstoreBulkId, setWeight, size, supportsReplicationFilter, toArray, toArray, toFilterEntries, updateTimeToLiveIfNeededMethods inherited from class Object
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface Collection
equals, hashCode, parallelStream, removeIf, spliterator, stream, toArrayMethods inherited from interface IReplicationPacketEntryData
getOperationId, getOrderCode, getTypeName, getUid, isBackupOnly, isFromGateway, isTransient, requiresRecoveryDuplicationProtectionMethods inherited from interface IReplicationTransactionalPacketEntryData
toFilterEntryMethods inherited from interface SmartExternalizable
enabledSmartExternalizableWithReference
-
Constructor Details
-
PartialUpdateReplicationPacketData
public PartialUpdateReplicationPacketData() -
PartialUpdateReplicationPacketData
public PartialUpdateReplicationPacketData(IEntryPacket entry, boolean fromGateway, boolean overrideVersion, IEntryData previousEntryData, long expertaionTime, IEntryData currentEntryData)
-
-
Method Details
-
clone
- Specified by:
clonein interfaceIReplicationPacketData<IReplicationPacketEntryData>- Specified by:
clonein interfaceIReplicationTransactionalPacketEntryData- Overrides:
clonein classUpdateReplicationPacketData
-
execute
public void execute(IReplicationInContext context, IReplicationInFacade inReplicationHandler, ReplicationPacketDataMediator dataMediator) throws Exception - Specified by:
executein interfaceIExecutableReplicationPacketData<IReplicationPacketEntryData>- Overrides:
executein classUpdateReplicationPacketData- Throws:
Exception
-
executeTransactional
public void executeTransactional(IReplicationInContext context, ITransactionalExecutionCallback transactionExecutionCallback, Transaction transaction, boolean twoPhaseCommit) throws Exception - Specified by:
executeTransactionalin interfaceIReplicationTransactionalPacketEntryData- Overrides:
executeTransactionalin classUpdateReplicationPacketData- Throws:
Exception
-
batchExecuteTransactional
public void batchExecuteTransactional(IReplicationInBatchContext context, ITransactionalBatchExecutionCallback executionCallback) throws Exception - Specified by:
batchExecuteTransactionalin interfaceIReplicationTransactionalPacketEntryData- Overrides:
batchExecuteTransactionalin classUpdateReplicationPacketData- Throws:
Exception
-
toString
- Overrides:
toStringin classUpdateReplicationPacketData
-
containsFullEntryData
public boolean containsFullEntryData()- Specified by:
containsFullEntryDatain interfaceIReplicationPacketEntryData- Overrides:
containsFullEntryDatain classSingleReplicationPacketData
-
serializePreviousEntryData
- Overrides:
serializePreviousEntryDatain classUpdateReplicationPacketData- Throws:
IOException
-
deserializePreviousEntryData
protected void deserializePreviousEntryData(ObjectInput in) throws IOException, ClassNotFoundException - Overrides:
deserializePreviousEntryDatain classUpdateReplicationPacketData- Throws:
IOExceptionClassNotFoundException
-
restoreCurrentEntryData
protected void restoreCurrentEntryData()- Overrides:
restoreCurrentEntryDatain classUpdateReplicationPacketData
-