Package org.infinispan.server.iteration

Class DefaultIterationManager

java.lang.Object

org.infinispan.server.iteration.DefaultIterationManager

All Implemented Interfaces:

IterationManager

Direct Known Subclasses:

ExternalSourceIterationManager

public class DefaultIterationManager
extends Object
implements IterationManager

Constructor Summary

Constructors

Constructor	Description
DefaultIterationManager(TimeService timeService)

Method Summary

Modifier and Type	Method	Description
int	activeIterations()
void	addKeyValueFilterConverterFactory(String name, KeyValueFilterConverterFactory factory)
protected CacheStream<CacheEntry<Object,Object>>	baseStream(AdvancedCache cache, IterationInitializationContext ctx)
IterationState	close(String iterationId)
IterableIterationResult	next(String iterationId, int batch)	Reds the next batch from the iterator associated with .
void	removeKeyValueFilterConverterFactory(String name)
IterationState	start(AdvancedCache cache, BitSet segments, String filterConverterFactory, List<byte[]> filterConverterParams, MediaType requestValueType, int batch, boolean metadata, DeliveryGuarantee guarantee, IterationInitializationContext ctx)

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultIterationManager

public DefaultIterationManager(TimeService timeService)

Method Details

start

public IterationState start(AdvancedCache cache,
 BitSet segments,
 String filterConverterFactory,
 List<byte[]> filterConverterParams,
 MediaType requestValueType,
 int batch,
 boolean metadata,
 DeliveryGuarantee guarantee,
 IterationInitializationContext ctx)

Specified by:

start in interface IterationManager

baseStream

protected CacheStream<CacheEntry<Object,Object>> baseStream(AdvancedCache cache,
 IterationInitializationContext ctx)

next

public IterableIterationResult next(String iterationId,
 int batch)

Description copied from interface: IterationManager

Reds the next batch from the iterator associated with .

Warning: This method can block.

Specified by:

next in interface IterationManager

Parameters:

iterationId - : The iterator identifier.

batch - : The maximum number of entries to include in the batch.

Returns:

An IterableIterationResult object with the current data and metadata about the iterator.

close

public IterationState close(String iterationId)

Specified by:

close in interface IterationManager

addKeyValueFilterConverterFactory

public void addKeyValueFilterConverterFactory(String name,
 KeyValueFilterConverterFactory factory)

Specified by:

addKeyValueFilterConverterFactory in interface IterationManager

removeKeyValueFilterConverterFactory

public void removeKeyValueFilterConverterFactory(String name)

Specified by:

removeKeyValueFilterConverterFactory in interface IterationManager

activeIterations

public int activeIterations()

Specified by:

activeIterations in interface IterationManager