Package org.infinispan.server.iteration

Class ExternalSourceIterationManager

java.lang.Object

org.infinispan.server.iteration.DefaultIterationManager

org.infinispan.server.iteration.ExternalSourceIterationManager

All Implemented Interfaces:

IterationManager

public class ExternalSourceIterationManager
extends DefaultIterationManager

A specialized implementation of DefaultIterationManager that is used when the source of the iteration is external to the cache.

The base stream is extracted from the IterationInitializationContext and wrapped in a LocalCacheStream. This makes it possible to still apply filters and converters to the stream. If no context is provided, defaults to an empty stream.

Since:

15.0

See Also:

• DefaultIterationManager

Constructor Summary

Constructors

Constructor	Description
ExternalSourceIterationManager(TimeService timeService)

Method Summary

Modifier and Type	Method	Description
protected CacheStream<CacheEntry<Object,Object>>	baseStream(AdvancedCache cache, IterationInitializationContext ctx)

Methods inherited from class org.infinispan.server.iteration.DefaultIterationManager

activeIterations, addKeyValueFilterConverterFactory, close, next, removeKeyValueFilterConverterFactory, start

Methods inherited from class java.lang.Object

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

Constructor Details

ExternalSourceIterationManager

public ExternalSourceIterationManager(TimeService timeService)

Method Details

baseStream

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

Overrides:

baseStream in class DefaultIterationManager