Class DefaultIterationManager
- java.lang.Object
-
- org.infinispan.server.hotrod.iteration.DefaultIterationManager
-
- All Implemented Interfaces:
IterationManager
public class DefaultIterationManager extends java.lang.Object implements IterationManager
-
-
Constructor Summary
Constructors Constructor Description DefaultIterationManager(TimeService timeService)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description int
activeIterations()
void
addKeyValueFilterConverterFactory(java.lang.String name, KeyValueFilterConverterFactory factory)
IterationState
close(java.lang.String iterationId)
IterableIterationResult
next(java.lang.String iterationId)
void
removeKeyValueFilterConverterFactory(java.lang.String name)
IterationState
start(Cache cache, java.util.BitSet segments, java.lang.String filterConverterFactory, java.util.List<byte[]> filterConverterParams, MediaType requestValueType, int batch, boolean metadata)
-
-
-
Constructor Detail
-
DefaultIterationManager
public DefaultIterationManager(TimeService timeService)
-
-
Method Detail
-
start
public IterationState start(Cache cache, java.util.BitSet segments, java.lang.String filterConverterFactory, java.util.List<byte[]> filterConverterParams, MediaType requestValueType, int batch, boolean metadata)
- Specified by:
start
in interfaceIterationManager
-
next
public IterableIterationResult next(java.lang.String iterationId)
- Specified by:
next
in interfaceIterationManager
-
close
public IterationState close(java.lang.String iterationId)
- Specified by:
close
in interfaceIterationManager
-
addKeyValueFilterConverterFactory
public void addKeyValueFilterConverterFactory(java.lang.String name, KeyValueFilterConverterFactory factory)
- Specified by:
addKeyValueFilterConverterFactory
in interfaceIterationManager
-
removeKeyValueFilterConverterFactory
public void removeKeyValueFilterConverterFactory(java.lang.String name)
- Specified by:
removeKeyValueFilterConverterFactory
in interfaceIterationManager
-
activeIterations
public int activeIterations()
- Specified by:
activeIterations
in interfaceIterationManager
-
-