com.gigaspaces.internal.cluster.node.impl.packets.data.operations

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>

public class PartialUpdateReplicationPacketData
extends UpdateReplicationPacketData

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class com.gigaspaces.internal.cluster.node.impl.packets.data.operations.AbstractReplicationPacketSingleEntryData

AbstractReplicationPacketSingleEntryData.SingleEntryIterator, AbstractReplicationPacketSingleEntryData.SingleFilterIterable

Field Summary

Fields inherited from class com.gigaspaces.internal.cluster.node.impl.packets.data.operations.UpdateReplicationPacketData

_currentEntryData, _flags, _previousEntryData

Constructor Summary

Constructors

Constructor and Description
PartialUpdateReplicationPacketData()
PartialUpdateReplicationPacketData(IEntryPacket entry, boolean fromGateway, boolean overrideVersion, IEntryData previousEntryData, long expertaionTime, IEntryData currentEntryData)

Method Summary

Modifier and Type	Method and Description
void	batchExecuteTransactional(IReplicationInBatchContext context, ITransactionalBatchExecutionCallback executionCallback)
PartialUpdateReplicationPacketData	clone()
boolean	containsFullEntryData()
protected void	deserializePreviousEntryData(ObjectInput in)
void	execute(IReplicationInContext context, IReplicationInFacade inReplicationHandler, ReplicationPacketDataMediator dataMediator)
void	executeTransactional(IReplicationInContext context, ITransactionalExecutionCallback transactionExecutionCallback, Transaction transaction, boolean twoPhaseCommit)
protected void	restoreCurrentEntryData()
protected void	serializePreviousEntryData(ObjectOutput out)
String	toString()

Methods inherited from class com.gigaspaces.internal.cluster.node.impl.packets.data.operations.UpdateReplicationPacketData

beforeDelayedReplication, filterIfNotPresentInReplicaState, getExpirationTime, getFilterObjectType, getFilterReplicationOpType, getFlags, getMainEntryData, getOperationType, getPreviousEntryData, getPreviousEntryPacket, getSecondaryEntryData, isOverrideVersion, isSerializeFullContent, readExternal, readFromSwap, readPreviousEntryData, serializeFullContent, writeExternal, writePreviousEntryData, writeToSwap

Methods inherited from class com.gigaspaces.internal.cluster.node.impl.packets.data.operations.SingleReplicationPacketData

cloneWithEntryPacket, getEntryPacket, getOperationId, getOrderCode, getTypeDescriptor, getUid, isTransient, toFilterEntry, updateEntryPacketTimeToLiveIfNeeded

Methods inherited from class com.gigaspaces.internal.cluster.node.impl.packets.data.operations.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, updateTimeToLiveIfNeeded

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.gigaspaces.internal.cluster.node.impl.packets.data.IReplicationTransactionalPacketEntryData

toFilterEntry

Methods inherited from interface com.gigaspaces.internal.cluster.node.impl.packets.data.IReplicationPacketEntryData

getOperationId, getOrderCode, getUid, isBackupOnly, isFromGateway, isTransient, requiresRecoveryDuplicationProtection

Methods inherited from interface com.gigaspaces.serialization.SmartExternalizable

enabledSmartExternalizableWithReference

Methods inherited from interface java.util.Collection

equals, hashCode, parallelStream, removeIf, spliterator, stream

Methods inherited from interface java.lang.Iterable

forEach

Constructor Detail

PartialUpdateReplicationPacketData

public PartialUpdateReplicationPacketData()

PartialUpdateReplicationPacketData

public PartialUpdateReplicationPacketData(IEntryPacket entry,
                                          boolean fromGateway,
                                          boolean overrideVersion,
                                          IEntryData previousEntryData,
                                          long expertaionTime,
                                          IEntryData currentEntryData)

Method Detail

clone

public PartialUpdateReplicationPacketData clone()

Specified by:

clone in interface IReplicationPacketData<IReplicationPacketEntryData>

Specified by:

clone in interface IReplicationTransactionalPacketEntryData

Overrides:

clone in class UpdateReplicationPacketData

execute

public void execute(IReplicationInContext context,
                    IReplicationInFacade inReplicationHandler,
                    ReplicationPacketDataMediator dataMediator)
             throws Exception

Specified by:

execute in interface IExecutableReplicationPacketData<IReplicationPacketEntryData>

Overrides:

execute in class UpdateReplicationPacketData

Throws:

Exception

executeTransactional

public void executeTransactional(IReplicationInContext context,
                                 ITransactionalExecutionCallback transactionExecutionCallback,
                                 Transaction transaction,
                                 boolean twoPhaseCommit)
                          throws Exception

Specified by:

executeTransactional in interface IReplicationTransactionalPacketEntryData

Overrides:

executeTransactional in class UpdateReplicationPacketData

Throws:

Exception

batchExecuteTransactional

public void batchExecuteTransactional(IReplicationInBatchContext context,
                                      ITransactionalBatchExecutionCallback executionCallback)
                               throws Exception

Specified by:

batchExecuteTransactional in interface IReplicationTransactionalPacketEntryData

Overrides:

batchExecuteTransactional in class UpdateReplicationPacketData

Throws:

Exception

toString

public String toString()

Overrides:

toString in class UpdateReplicationPacketData

containsFullEntryData

public boolean containsFullEntryData()

Specified by:

containsFullEntryData in interface IReplicationPacketEntryData

Overrides:

containsFullEntryData in class SingleReplicationPacketData

serializePreviousEntryData

protected void serializePreviousEntryData(ObjectOutput out)
                                   throws IOException

Overrides:

serializePreviousEntryData in class UpdateReplicationPacketData

Throws:

IOException

deserializePreviousEntryData

protected void deserializePreviousEntryData(ObjectInput in)
                                     throws IOException,
                                            ClassNotFoundException

Overrides:

deserializePreviousEntryData in class UpdateReplicationPacketData

Throws:

IOException

ClassNotFoundException

restoreCurrentEntryData

protected void restoreCurrentEntryData()

Overrides:

restoreCurrentEntryData in class UpdateReplicationPacketData