Package com.gigaspaces.client.iterator.cursor

Class SpaceIteratorBatchResultProvider

java.lang.Object

com.gigaspaces.client.iterator.cursor.SpaceIteratorBatchResultProvider

All Implemented Interfaces:

Serializable

public class SpaceIteratorBatchResultProvider
extends Object
implements Serializable

Since:

15.2.0

Author:

Alon Shoham

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
SpaceIteratorBatchResultProvider(ISpaceProxy spaceProxy, int batchSize, int readModifiers, ITemplatePacket queryPacket, UUID uuid, long maxInactiveDuration)

Method Summary

Modifier and Type	Method	Description
void	addAsyncBatchResult(AsyncResult<SpaceIteratorBatchResult> spaceIteratorBatchAsyncResult)
void	addBatchResult(SpaceIteratorBatchResult spaceIteratorBatchResult)
void	close()
SpaceIteratorBatchResult	consumeBatch(long timeout)
int	getBatchSize()
int	getInitialNumberOfActivePartitions()
long	getMaxInactiveDuration()
int	getNumberOfPartitions()
ITemplatePacket	getQueryPacket()
int	getReadModifiers()
ISpaceProxy	getSpaceProxy()
UUID	getUuid()
void	renewIteratorLease()
void	triggerSinglePartitionBatchTask(int partitionId, int batchNumber)

Methods inherited from class java.lang.Object

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

Constructor Details

SpaceIteratorBatchResultProvider

public SpaceIteratorBatchResultProvider(ISpaceProxy spaceProxy,
 int batchSize,
 int readModifiers,
 ITemplatePacket queryPacket,
 UUID uuid,
 long maxInactiveDuration)

Method Details

addBatchResult

public void addBatchResult(SpaceIteratorBatchResult spaceIteratorBatchResult)

addAsyncBatchResult

public void addAsyncBatchResult(AsyncResult<SpaceIteratorBatchResult> spaceIteratorBatchAsyncResult)

consumeBatch

public SpaceIteratorBatchResult consumeBatch(long timeout)
                                      throws InterruptedException

Throws:

InterruptedException

triggerSinglePartitionBatchTask

public void triggerSinglePartitionBatchTask(int partitionId,
 int batchNumber)
                                     throws RemoteException,
TransactionException

Throws:

RemoteException

TransactionException

close

public void close()

getBatchSize

public int getBatchSize()

getReadModifiers

public int getReadModifiers()

getQueryPacket

public ITemplatePacket getQueryPacket()

getUuid

public UUID getUuid()

getNumberOfPartitions

public int getNumberOfPartitions()

getMaxInactiveDuration

public long getMaxInactiveDuration()

getInitialNumberOfActivePartitions

public int getInitialNumberOfActivePartitions()

getSpaceProxy

public ISpaceProxy getSpaceProxy()

renewIteratorLease

public void renewIteratorLease()