Class MultiBucketSingleFileBatchConsumeTargetProcessLog

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.processlog.AbstractSingleFileTargetProcessLog

com.gigaspaces.internal.cluster.node.impl.processlog.multibucketsinglefile.AbstractMultiBucketSingleFileTargetProcessLog

com.gigaspaces.internal.cluster.node.impl.processlog.multibucketsinglefile.MultiBucketSingleFileBatchConsumeTargetProcessLog

All Implemented Interfaces:

IReplicationAsyncTargetProcessLog, IReplicationBatchConsumeAsyncTargetProcessLog, IReplicationTargetProcessLog, IBatchExecutedCallback, IMultiBucketSingleFileProcessLog

Direct Known Subclasses:

MultiBucketSingleFileReliableAsyncTargetProcessLog

public class MultiBucketSingleFileBatchConsumeTargetProcessLog
extends AbstractMultiBucketSingleFileTargetProcessLog
implements IBatchExecutedCallback, IReplicationBatchConsumeAsyncTargetProcessLog

Field Summary

Fields

Modifier and Type	Field	Description
protected final Lock	_lock

Fields inherited from class AbstractSingleFileTargetProcessLog

_dataConsumer, _specificLogger

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	MultiBucketSingleFileBatchConsumeTargetProcessLog(ProcessLogConfig config, IReplicationPacketDataBatchConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, long lastGlobalProcessedKey, long[] lastProcessedKeys, long[] lastGlobalProcessedKeys, boolean firstHandshakeForTarget, IReplicationGroupHistory groupHistory)
	MultiBucketSingleFileBatchConsumeTargetProcessLog(ProcessLogConfig config, IReplicationPacketDataBatchConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, IReplicationGroupHistory groupHistory)

Method Summary

Modifier and Type	Method	Description
void	batchConsumed(ShortLongMap bucketProcessedKeys, ShortLongMap bucketGlobalProcessedKeys, long lastGlobalprocessedKey)
protected boolean	contentRequiredWhileProcessing()
protected String	dumpStateExtra()
protected boolean	filterDuplicate(IReplicationOrderedPacket packet)
protected void	filterDuplicate(List<IReplicationOrderedPacket> packets)
long	getLastGlobalProcessedKey()
MultiBucketSingleFileHandshakeResponse	performHandshake(String memberName, IBacklogHandshakeRequest handshakeRequest)
MultiBucketSingleFileProcessResult	process(String sourceLookupName, IReplicationOrderedPacket packet, IReplicationInFilterCallback inFilterCallback)
MultiBucketSingleFileProcessResult	processBatch(String sourceLookupName, List<IReplicationOrderedPacket> packets, IReplicationInFilterCallback inFilterCallback)

Methods inherited from class AbstractMultiBucketSingleFileTargetProcessLog

afterSuccessfulConsumption, canResetState, close, createBatchParallelProcessingContinuationTask, dumpState, getConsumeTimeout, getExecutorService, getLastGlobalProcessedKeys, getLastProcessedKeys, getSpecificLogger, isFirstHandshakeForTarget, process, process, process, process, process, processHandshakeIteration, processIdleStateData, resync, shouldCloneOnFilter, throwClosedException, toWireForm, validateNotClosed, validateOpen

Methods inherited from class AbstractSingleFileTargetProcessLog

createReplicationInContext, getDataConsumer, getExceptionHandler, getGroupHistory, getGroupName, getReplicationInContext, getReplicationInFacade, getSourceLookupName, throwIfRepetitiveError, toLogMessage

Methods inherited from class Object

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

Methods inherited from interface IReplicationTargetProcessLog

close, dumpState, getDataConsumer, processHandshakeIteration, processIdleStateData, resync, toLogMessage, toWireForm

Field Details

_lock

protected final Lock _lock

Constructor Details

MultiBucketSingleFileBatchConsumeTargetProcessLog

public MultiBucketSingleFileBatchConsumeTargetProcessLog(ProcessLogConfig config,
 IReplicationPacketDataBatchConsumer<?> dataConsumer,
 IReplicationProcessLogExceptionHandler exceptionHandler,
 IReplicationInFacade replicationInFacade,
 String name,
 String groupName,
 String sourceLookupName,
 IReplicationGroupHistory groupHistory)

MultiBucketSingleFileBatchConsumeTargetProcessLog

protected MultiBucketSingleFileBatchConsumeTargetProcessLog(ProcessLogConfig config,
 IReplicationPacketDataBatchConsumer<?> dataConsumer,
 IReplicationProcessLogExceptionHandler exceptionHandler,
 IReplicationInFacade replicationInFacade,
 String name,
 String groupName,
 String sourceLookupName,
 long lastGlobalProcessedKey,
 long[] lastProcessedKeys,
 long[] lastGlobalProcessedKeys,
 boolean firstHandshakeForTarget,
 IReplicationGroupHistory groupHistory)

Method Details

contentRequiredWhileProcessing

protected boolean contentRequiredWhileProcessing()

Specified by:

contentRequiredWhileProcessing in class AbstractSingleFileTargetProcessLog

performHandshake

public MultiBucketSingleFileHandshakeResponse performHandshake(String memberName,
 IBacklogHandshakeRequest handshakeRequest)
                                                        throws IncomingReplicationOutOfSyncException

Specified by:

performHandshake in interface IReplicationTargetProcessLog

Overrides:

performHandshake in class AbstractMultiBucketSingleFileTargetProcessLog

Throws:

IncomingReplicationOutOfSyncException

processBatch

public MultiBucketSingleFileProcessResult processBatch(String sourceLookupName,
 List<IReplicationOrderedPacket> packets,
 IReplicationInFilterCallback inFilterCallback)

Specified by:

processBatch in interface IReplicationTargetProcessLog

Overrides:

processBatch in class AbstractMultiBucketSingleFileTargetProcessLog

process

public MultiBucketSingleFileProcessResult process(String sourceLookupName,
 IReplicationOrderedPacket packet,
 IReplicationInFilterCallback inFilterCallback)

Specified by:

process in interface IReplicationTargetProcessLog

Overrides:

process in class AbstractMultiBucketSingleFileTargetProcessLog

batchConsumed

public void batchConsumed(ShortLongMap bucketProcessedKeys,
 ShortLongMap bucketGlobalProcessedKeys,
 long lastGlobalprocessedKey)

Specified by:

batchConsumed in interface IBatchExecutedCallback

filterDuplicate

protected void filterDuplicate(List<IReplicationOrderedPacket> packets)

filterDuplicate

protected boolean filterDuplicate(IReplicationOrderedPacket packet)

getLastGlobalProcessedKey

public long getLastGlobalProcessedKey()

dumpStateExtra

protected String dumpStateExtra()

Overrides:

dumpStateExtra in class AbstractMultiBucketSingleFileTargetProcessLog