MultiBucketSingleFileProcessResult |
ProcessLogBucket.addAndProcess(String sourceLookupName,
IMultiBucketSingleFileReplicationOrderedPacket packet,
IReplicationInFilterCallback inFilterCallback,
ParallelBatchProcessingContext batchContext,
int segmentIndex) |
MultiBucketSingleFileProcessResult |
AbstractMultiBucketSingleFileTargetProcessLog.process(String sourceLookupName,
DeletedMultiBucketOrderedPacket packet,
IReplicationInFilterCallback inFilterCallback,
ParallelBatchProcessingContext batchContext,
int segmentIndex) |
MultiBucketSingleFileProcessResult |
IMultiBucketSingleFileProcessLog.process(String sourceLookupName,
DeletedMultiBucketOrderedPacket packet,
IReplicationInFilterCallback inFilterCallback,
ParallelBatchProcessingContext batchContext,
int segmentIndex) |
MultiBucketSingleFileProcessResult |
AbstractMultiBucketSingleFileTargetProcessLog.process(String sourceLookupName,
DiscardedMultiBucketOrderedPacket packet,
IReplicationInFilterCallback inFilterCallback,
ParallelBatchProcessingContext batchContext,
int segmentIndex) |
MultiBucketSingleFileProcessResult |
IMultiBucketSingleFileProcessLog.process(String sourceLookupName,
DiscardedMultiBucketOrderedPacket packet,
IReplicationInFilterCallback inFilterCallback,
ParallelBatchProcessingContext batchContext,
int segmentIndex) |
MultiBucketSingleFileProcessResult |
AbstractMultiBucketSingleFileTargetProcessLog.process(String sourceLookupName,
IReplicationOrderedPacket packet,
IReplicationInFilterCallback inFilterCallback) |
MultiBucketSingleFileProcessResult |
MultiBucketSingleFileBatchConsumeTargetProcessLog.process(String sourceLookupName,
IReplicationOrderedPacket packet,
IReplicationInFilterCallback inFilterCallback) |
MultiBucketSingleFileProcessResult |
AbstractMultiBucketSingleFileTargetProcessLog.process(String sourceLookupName,
IReplicationOrderedPacket packet,
IReplicationInFilterCallback inFilterCallback,
ParallelBatchProcessingContext batchContext,
int segmentIndex) |
MultiBucketSingleFileProcessResult |
AbstractMultiBucketSingleFileTargetProcessLog.process(String sourceLookupName,
ISingleBucketReplicationOrderedPacket packet,
IReplicationInFilterCallback inFilterCallback,
ParallelBatchProcessingContext batchContext,
int segmentIndex) |
MultiBucketSingleFileProcessResult |
IMultiBucketSingleFileProcessLog.process(String sourceLookupName,
ISingleBucketReplicationOrderedPacket packet,
IReplicationInFilterCallback inFilterCallback,
ParallelBatchProcessingContext batchContext,
int segmentIndex) |
MultiBucketSingleFileProcessResult |
AbstractMultiBucketSingleFileTargetProcessLog.process(String sourceLookupName,
MultipleBucketOrderedPacket packet,
IReplicationInFilterCallback inFilterCallback,
ParallelBatchProcessingContext batchContext,
int segmentIndex) |
MultiBucketSingleFileProcessResult |
IMultiBucketSingleFileProcessLog.process(String sourceLookupName,
MultipleBucketOrderedPacket packet,
IReplicationInFilterCallback inFilterCallback,
ParallelBatchProcessingContext batchContext,
int segmentIndex) |
MultiBucketSingleFileProcessResult |
AbstractMultiBucketSingleFileTargetProcessLog.processBatch(String sourceLookupName,
List<IReplicationOrderedPacket> packets,
IReplicationInFilterCallback inFilterCallback) |
MultiBucketSingleFileProcessResult |
MultiBucketSingleFileBatchConsumeTargetProcessLog.processBatch(String sourceLookupName,
List<IReplicationOrderedPacket> packets,
IReplicationInFilterCallback inFilterCallback) |