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 and Description
ParallelBatchProcessingContext(List<IReplicationOrderedPacket>[] parallelLists, int parallelParticipants)

Method Summary

Modifier and Type	Method and 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 Detail

ParallelBatchProcessingContext

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

Method Detail

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)