| Modifier and Type | Class and Description | 
|---|---|
class  | 
DataTypeAddIndexPacketData  | 
class  | 
DataTypeIntroducePacketData  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
SynchronizingData<T extends IReplicationPacketData<?>>  | 
| Modifier and Type | Method and Description | 
|---|---|
IReplicationPacketData<?> | 
GlobalOrderDiscardedReplicationPacket.getData()  | 
IReplicationPacketData<?> | 
GlobalOrderReliableAsyncKeptDiscardedOrderedPacket.getData()  | 
IReplicationPacketData | 
GlobalOrderOperationPacket.getData()  | 
IReplicationPacketData | 
GlobalOrderDeletedBacklogPacket.getData()  | 
| Modifier and Type | Method and Description | 
|---|---|
IReplicationOrderedPacket | 
GlobalOrderDiscardedReplicationPacket.cloneWithNewData(IReplicationPacketData<?> newData)  | 
IReplicationOrderedPacket | 
GlobalOrderReliableAsyncKeptDiscardedOrderedPacket.cloneWithNewData(IReplicationPacketData<?> newData)  | 
IReplicationOrderedPacket | 
GlobalOrderOperationPacket.cloneWithNewData(IReplicationPacketData<?> newData)  | 
IReplicationOrderedPacket | 
GlobalOrderDeletedBacklogPacket.cloneWithNewData(IReplicationPacketData<?> newData)  | 
| Constructor and Description | 
|---|
GlobalOrderOperationPacket(long key,
                          IReplicationPacketData data)  | 
| Modifier and Type | Method and Description | 
|---|---|
IReplicationPacketData<?> | 
MultiBucketSingleFileReliableAsyncKeptDiscardedPacket.getData()  | 
IReplicationPacketData<?> | 
SingleBucketOrderedPacket.getData()  | 
IReplicationPacketData<?> | 
MultipleBucketOrderedPacket.getData()  | 
IReplicationPacketData<?> | 
DeletedMultiBucketOrderedPacket.getData()  | 
IReplicationPacketData<?> | 
DiscardedMultiBucketOrderedPacket.getData()  | 
IReplicationPacketData<?> | 
DiscardedSingleBucketOrderedPacket.getData()  | 
| Constructor and Description | 
|---|
MultipleBucketOrderedPacket(long globalKey,
                           ShortObjectMap<BucketKey> bucketsKeys,
                           IReplicationPacketData<?> data)  | 
SingleBucketOrderedPacket(long globalKey,
                         long bucketKey,
                         short bucketIndex,
                         IReplicationPacketData<?> data)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
IReplicationInFilterCallback.invokeInFilter(IReplicationInContext context,
              IReplicationPacketData<?> data)
Callback method for the data consumer to invoke input filters before executing the packet 
 | 
| Modifier and Type | Method and Description | 
|---|---|
ReplicationChannelEntryDataFilterResult | 
NotificationReplicationChannelDataFilter.filterBeforeReplicatingEntryData(IReplicationPacketEntryData packetEntryData,
                                PlatformLogicalVersion targetLogicalVersion,
                                IReplicationPacketEntryDataContentExtractor contentExtractor,
                                Logger contextLogger,
                                IReplicationPacketData<?> data)  | 
| Modifier and Type | Method and Description | 
|---|---|
IReplicationPacketData<?> | 
IReplicationOrderedPacket.getData()  | 
| Modifier and Type | Method and Description | 
|---|---|
IReplicationOrderedPacket | 
IReplicationOrderedPacket.cloneWithNewData(IReplicationPacketData<?> newData)
Clones the packet replacing its data with the new data 
 | 
| Modifier and Type | Interface and Description | 
|---|---|
interface  | 
IReplicationPacketDataBatchConsumer<T extends IReplicationPacketData<?>>  | 
interface  | 
IReplicationPacketDataConsumer<T extends IReplicationPacketData<?>>
Consumes  
IReplicationPacketData and delegate it to the corresponding replication in
 handler. | 
interface  | 
IReplicationPacketDataProducer<T extends IReplicationPacketData<?>>
Convert logical operation to a representing  
IReplicationPacketData | 
| Modifier and Type | Interface and Description | 
|---|---|
interface  | 
IExecutableReplicationPacketData<T extends IReplicationPacketEntryData>
An extension of  
IReplicationPacketData that can be self executed. | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
DiscardReplicationPacketData  | 
| Modifier and Type | Method and Description | 
|---|---|
IReplicationPacketData<T> | 
IReplicationPacketData.clone()  | 
IReplicationPacketData<?> | 
IReplicationPacketDataConsumer.merge(IReplicationPacketData<?>[] allParticipantsData,
     IReplicationParticipantsMetadata participantsMetadata)
Merges data of multiple participants operations to a single operation data which will
 eventually be executed as one. 
 | 
IReplicationPacketData<?> | 
ReplicationPacketDataConsumer.merge(IReplicationPacketData<?>[] allParticipantsData,
     IReplicationParticipantsMetadata participantsMetadata)  | 
| Modifier and Type | Method and Description | 
|---|---|
IReplicationParticipantsMetadata | 
IReplicationPacketDataConsumer.extractParticipantsMetadata(IReplicationPacketData<?> data)
Extracts participants meta data for the provided replication packet data 
 | 
IReplicationParticipantsMetadata | 
ReplicationPacketDataConsumer.extractParticipantsMetadata(IReplicationPacketData<?> data)  | 
IReplicationPacketData<?> | 
IReplicationPacketDataConsumer.merge(IReplicationPacketData<?>[] allParticipantsData,
     IReplicationParticipantsMetadata participantsMetadata)
Merges data of multiple participants operations to a single operation data which will
 eventually be executed as one. 
 | 
IReplicationPacketData<?> | 
ReplicationPacketDataConsumer.merge(IReplicationPacketData<?>[] allParticipantsData,
     IReplicationParticipantsMetadata participantsMetadata)  | 
Iterable<IReplicationFilterEntry> | 
IReplicationPacketDataConsumer.toFilterEntries(IReplicationInContext context,
               IReplicationPacketData<?> data)
Transform generated data to filter entry in order to be passed to a filter 
 | 
Iterable<IReplicationFilterEntry> | 
ReplicationPacketDataConsumer.toFilterEntries(IReplicationInContext context,
               IReplicationPacketData<?> data)  | 
| Modifier and Type | Method and Description | 
|---|---|
<T extends IReplicationPacketData<?>> | 
AbstractSingleFileTargetProcessLog.getDataConsumer()  | 
<T extends IReplicationPacketData<?>> | 
IReplicationTargetProcessLog.getDataConsumer()  | 
| Modifier and Type | Method and Description | 
|---|---|
IReplicationPacketData<?>[] | 
IReplicationParticipantsMediator.getAllParticipantsData(MultiSourceProcessLogPacket packet)
Gets all data for a multiple participants replication operation. 
 | 
IReplicationPacketData<?>[] | 
ReplicationParticipantsMediator.getAllParticipantsData(MultiSourceProcessLogPacket packet)  | 
IReplicationPacketData<?> | 
MultiSourceProcessLogMultiParticipantPacket.getData()  | 
IReplicationPacketData<?> | 
MultiSourceProcessLogPacket.getData()  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
MultiSourceProcessLogMultiParticipantPacket.setData(IReplicationPacketData<?> mergedData)  | 
void | 
MultiSourceProcessLogPacket.setData(IReplicationPacketData<?> mergedData)  | 
| Modifier and Type | Method and Description | 
|---|---|
ReplicationChannelEntryDataFilterResult | 
ViewReplicationChannelDataFilter.filterBeforeReplicatingEntryData(IReplicationPacketEntryData entryData,
                                PlatformLogicalVersion targetLogicalVersion,
                                IReplicationPacketEntryDataContentExtractor contentExtractor,
                                Logger contextLogger,
                                IReplicationPacketData data)  | 
Copyright © GigaSpaces.