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

Class ProcessLogBucket

java.lang.Object

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

public class ProcessLogBucket
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ProcessLogBucket.MultiBucketSingleFileOrderedPacketComperator

Constructor Summary

Constructors

Constructor	Description
ProcessLogBucket(short bucketIndex, AbstractMultiBucketSingleFileTargetProcessLog processLog)

Method Summary

Modifier and Type	Method	Description
void	add(List<IMultiBucketSingleFileReplicationOrderedPacket> packets)
MultiBucketSingleFileProcessResult	addAndProcess(String sourceLookupName, IMultiBucketSingleFileReplicationOrderedPacket packet, IReplicationInFilterCallback inFilterCallback, ParallelBatchProcessingContext batchContext, int segmentIndex)
boolean	close(long time, TimeUnit unit)
protected boolean	filterDuplicate(IMultiBucketSingleFileReplicationOrderedPacket packet)
String	printPendingState()
Throwable	process(String sourceLookupName, List<IMultiBucketSingleFileReplicationOrderedPacket> bucketPackets, IReplicationInFilterCallback inFilterCallback)
void	releaseOnErrorResult(Throwable error)
void	signalDoneProcessing(String sourceLookupName, MultipleBucketOrderedPacket packet, IReplicationInFilterCallback inFilterCallback)

Methods inherited from class java.lang.Object

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

Constructor Details

ProcessLogBucket

public ProcessLogBucket(short bucketIndex,
 AbstractMultiBucketSingleFileTargetProcessLog processLog)

Method Details

releaseOnErrorResult

public void releaseOnErrorResult(Throwable error)

addAndProcess

public MultiBucketSingleFileProcessResult addAndProcess(String sourceLookupName,
 IMultiBucketSingleFileReplicationOrderedPacket packet,
 IReplicationInFilterCallback inFilterCallback,
 ParallelBatchProcessingContext batchContext,
 int segmentIndex)
                                                 throws Throwable

Throws:

Throwable

signalDoneProcessing

public void signalDoneProcessing(String sourceLookupName,
 MultipleBucketOrderedPacket packet,
 IReplicationInFilterCallback inFilterCallback)

add

public void add(List<IMultiBucketSingleFileReplicationOrderedPacket> packets)

process

public Throwable process(String sourceLookupName,
 List<IMultiBucketSingleFileReplicationOrderedPacket> bucketPackets,
 IReplicationInFilterCallback inFilterCallback)
                  throws Throwable

Throws:

Throwable

printPendingState

public String printPendingState()

filterDuplicate

protected boolean filterDuplicate(IMultiBucketSingleFileReplicationOrderedPacket packet)

close

public boolean close(long time,
 TimeUnit unit)
              throws InterruptedException

Throws:

InterruptedException