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

Interface IExecutableReplicationPacketData<T extends IReplicationPacketEntryData>

All Superinterfaces:

Cloneable, Collection<T>, Externalizable, IReplicationPacketData<T>, ISwapExternalizable, Iterable<T>, Serializable, SmartExternalizable

All Known Implementing Classes:

AbstractPrepareDependentTransactionReplicationPacketData, AbstractReplicationPacketSingleEntryData, AbstractTransactionReplicationPacketData, CancelLeaseFullReplicationPacketData, CancelLeaseReplicationPacketData, ChangeReplicationPacketData, DataTypeAddIndexPacketData, DataTypeDropPacketData, DataTypeIntroducePacketData, DiscardReplicationPacketData, EntryLeaseExpiredFullReplicationPacketData, EntryLeaseExpiredReplicationPacketData, EvictReplicationPacketData, ExtendEntryLeaseReplicationPacketData, ExtendNotifyTemplateLeaseReplicationPacketData, InsertNotifyTemplateReplicationPacketData, NotifyTemplateLeaseExpiredReplicationPacketData, PartialUpdateReplicationPacketData, RemoveByUIDReplicationPacketData, RemoveNotifyTemplateReplicationPacketData, RemoveReplicationPacketData, SingleReplicationPacketData, SingleUidReplicationPacketData, TransactionAbortReplicationPacketData, TransactionCommitReplicationPacketData, TransactionOnePhaseReplicationPacketData, TransactionPrepareReplicationPacketData, TransactionReplicationPacketData, UpdateReplicationPacketData, WriteReplicationPacketData

public interface IExecutableReplicationPacketData<T extends IReplicationPacketEntryData>
extends IReplicationPacketData<T>

An extension of IReplicationPacketData that can be self executed.

Since:

8.0

Author:

anna

Method Summary

Modifier and Type	Method and Description
IExecutableReplicationPacketData<T>	createEmptyMultipleEntryData()
void	execute(IReplicationInContext context, IReplicationInFacade inReplicationHandler, ReplicationPacketDataMediator dataMediator)
boolean	isPartOfBlobstoreBulk()
Iterable<IReplicationFilterEntry>	toFilterEntries(SpaceTypeManager spaceTypeManager)

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

beforeDelayedReplication, clone, getMultipleOperationType, getRecoveryFilteringId, getSingleEntryData, getWeight, isFromGateway, isMultiParticipantData, isSingleEntryData, requiresRecoveryFiltering, setWeight, supportsReplicationFilter

Methods inherited from interface java.util.Collection

add, addAll, clear, contains, containsAll, equals, hashCode, isEmpty, iterator, parallelStream, remove, removeAll, removeIf, retainAll, size, spliterator, stream, toArray, toArray

Methods inherited from interface java.lang.Iterable

forEach

Methods inherited from interface com.gigaspaces.serialization.SmartExternalizable

enabledSmartExternalizableWithReference

Methods inherited from interface java.io.Externalizable

readExternal, writeExternal

Methods inherited from interface com.gigaspaces.internal.server.space.redolog.storage.bytebuffer.ISwapExternalizable

readFromSwap, writeToSwap

Method Detail

execute

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

Throws:

Exception

toFilterEntries

Iterable<IReplicationFilterEntry> toFilterEntries(SpaceTypeManager spaceTypeManager)

createEmptyMultipleEntryData

IExecutableReplicationPacketData<T> createEmptyMultipleEntryData()

isPartOfBlobstoreBulk

boolean isPartOfBlobstoreBulk()