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

Class ParallelBatchProcessingContext

java.lang.Object

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

public class ParallelBatchProcessingContext
extends Object

Constructor Summary

Constructors

Constructor	Description
ParallelBatchProcessingContext(List<IReplicationOrderedPacket>[] parallelLists, int parallelParticipants)

Method Summary

Modifier and Type	Method	Description
List<IReplicationOrderedPacket>	getSegment(int segmentIndex)
void	setError(Throwable error)
void	signalOneProcessedOk()
void	waitForCompletion(long timeout, TimeUnit units)

Methods inherited from class java.lang.Object

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

Constructor Details

ParallelBatchProcessingContext

public ParallelBatchProcessingContext(List<IReplicationOrderedPacket>[] parallelLists,
 int parallelParticipants)

Method Details

waitForCompletion

public void waitForCompletion(long timeout,
 TimeUnit units)
                       throws Throwable

Throws:

Throwable

signalOneProcessedOk

public void signalOneProcessedOk()

setError

public void setError(Throwable error)

getSegment

public List<IReplicationOrderedPacket> getSegment(int segmentIndex)