Uses of Interface
org.infinispan.commons.util.CloseableIterator

Packages that use CloseableIterator

Package	Description
org.infinispan	This is the core of Infinispan, a distributed, transactional, highly scalable data grid platform.
org.infinispan.cache.impl
org.infinispan.client.hotrod	Hot Rod client API.
org.infinispan.client.hotrod.impl
org.infinispan.commons.util	Commons package providing various utility classes
org.infinispan.functional.impl
org.infinispan.persistence.sifs	Soft Index AdvancedLoadWriteStore.
org.infinispan.query.dsl	Query DSL API.
org.infinispan.query.impl	Query module internals.
org.infinispan.server.hotrod
org.infinispan.stream.impl
org.infinispan.util	General utilities that are not specific to Infinispan, including string parsing helpers, reflection tools and collections and containers designed to supplement the JDK-provided containers.

Uses of CloseableIterator in org.infinispan

Methods in org.infinispan that return CloseableIterator

Modifier and Type	Method	Description
final CloseableIterator<E>	InternalCacheSet.iterator()

Uses of CloseableIterator in org.infinispan.cache.impl

Methods in org.infinispan.cache.impl that return CloseableIterator

Modifier and Type	Method	Description
CloseableIterator<E>	AbstractCacheBackedSet.iterator()
CloseableIterator<CacheEntry<K,V>>	SimpleCacheImpl.CacheEntrySet.iterator()
CloseableIterator<Map.Entry<K,V>>	SimpleCacheImpl.EntrySet.iterator()
CloseableIterator<K>	SimpleCacheImpl.KeySet.iterator()
CloseableIterator<V>	SimpleCacheImpl.Values.iterator()

Uses of CloseableIterator in org.infinispan.client.hotrod

Methods in org.infinispan.client.hotrod that return CloseableIterator

Modifier and Type	Method	Description
default CloseableIterator<Map.Entry<Object,Object>>	RemoteCache.retrieveEntries(String filterConverterFactory, int batchSize)
CloseableIterator<Map.Entry<Object,Object>>	RemoteCache.retrieveEntries(String filterConverterFactory, Object[] filterConverterParams, Set<Integer> segments, int batchSize)	Retrieve entries from the server.
default CloseableIterator<Map.Entry<Object,Object>>	RemoteCache.retrieveEntries(String filterConverterFactory, Set<Integer> segments, int batchSize)
CloseableIterator<Map.Entry<Object,Object>>	RemoteCache.retrieveEntriesByQuery(Query<?> filterQuery, Set<Integer> segments, int batchSize)	Retrieve entries from the server matching a query.
CloseableIterator<Map.Entry<Object,MetadataValue<Object>>>	RemoteCache.retrieveEntriesWithMetadata(Set<Integer> segments, int batchSize)	Retrieve entries with metadata information

Uses of CloseableIterator in org.infinispan.client.hotrod.impl

Methods in org.infinispan.client.hotrod.impl that return CloseableIterator

Modifier and Type	Method	Description
CloseableIterator<Map.Entry<K,V>>	DelegatingRemoteCache.entryIterator(IntSet segments)
CloseableIterator<Map.Entry<K,V>>	InternalRemoteCache.entryIterator(IntSet segments)
CloseableIterator<Map.Entry<K,V>>	RemoteCacheImpl.entryIterator(IntSet segments)
CloseableIterator<K>	DelegatingRemoteCache.keyIterator(IntSet segments)
CloseableIterator<K>	InternalRemoteCache.keyIterator(IntSet segments)
CloseableIterator<K>	RemoteCacheImpl.keyIterator(IntSet segments)
CloseableIterator<Map.Entry<Object,Object>>	DelegatingRemoteCache.retrieveEntries(String filterConverterFactory, Object[] filterConverterParams, Set<Integer> segments, int batchSize)
CloseableIterator<Map.Entry<Object,Object>>	RemoteCacheImpl.retrieveEntries(String filterConverterFactory, Object[] filterConverterParams, Set<Integer> segments, int batchSize)
CloseableIterator<Map.Entry<Object,Object>>	DelegatingRemoteCache.retrieveEntriesByQuery(Query<?> filterQuery, Set<Integer> segments, int batchSize)
CloseableIterator<Map.Entry<Object,Object>>	RemoteCacheImpl.retrieveEntriesByQuery(Query<?> filterQuery, Set<Integer> segments, int batchSize)
CloseableIterator<Map.Entry<Object,MetadataValue<Object>>>	DelegatingRemoteCache.retrieveEntriesWithMetadata(Set<Integer> segments, int batchSize)
CloseableIterator<Map.Entry<Object,MetadataValue<Object>>>	RemoteCacheImpl.retrieveEntriesWithMetadata(Set<Integer> segments, int batchSize)

Uses of CloseableIterator in org.infinispan.commons.util

Classes in org.infinispan.commons.util that implement CloseableIterator

Modifier and Type	Class	Description
class	ConcatIterator<E>	Iterator that concatenates a bunch of iterables into 1 big iterator.
class	FilterIterator<E>	Iterator that also filters out entries based on the provided predicate.
class	IteratorMapper<E,S>	A iterator that maps each value to the output of the Function.
class	RemovableCloseableIterator<C>	A CloseableIterator implementation that allows for a CloseableIterator that doesn't allow remove operations to implement remove by delegating the call to the provided consumer to remove the previously read value.

Fields in org.infinispan.commons.util declared as CloseableIterator

Modifier and Type	Field	Description
protected final CloseableIterator<C>	RemovableCloseableIterator.realIterator

Methods in org.infinispan.commons.util that return CloseableIterator

Modifier and Type	Method	Description
CloseableIterator<E>	CloseableIterable.iterator()
CloseableIterator<E>	CloseableIteratorCollection.iterator()
CloseableIterator<E>	CloseableIteratorCollectionAdapter.iterator()
static <E> CloseableIterator<E>	Closeables.iterator(Iterator<? extends E> iterator)	Creates a closeable iterator from the given iterator that does nothing when close is called.
static <R> CloseableIterator<R>	Closeables.iterator(BaseStream<R,Stream<R>> stream)	Creates a closeable iterator that when closed will close the underlying stream as well
static <E> CloseableIterator<E>	Closeables.iterator(org.reactivestreams.Publisher<E> publisher, int fetchSize)	Converts a Publisher to a CloseableIterator by utilizing items fetched into an array and refetched as they are consumed from the iterator.

Methods in org.infinispan.commons.util with parameters of type CloseableIterator

Modifier and Type	Method	Description
static <E> CloseableSpliterator<E>	Closeables.spliterator(CloseableIterator<? extends E> iterator, long size, int characteristics)	Takes a provided closeable iterator and wraps it appropriately so it can be used as a closeable spliterator that will close the iterator when the spliterator is closed.
static <E> Stream<E>	Closeables.stream(CloseableIterator<E> iterator, boolean parallel, long size, int characteristics)	Creates a stream that when closed will also close the underlying iterator

Constructors in org.infinispan.commons.util with parameters of type CloseableIterator

Modifier	Constructor	Description
	RemovableCloseableIterator(CloseableIterator<C> realIterator, Consumer<? super C> consumer)

Uses of CloseableIterator in org.infinispan.functional.impl

Methods in org.infinispan.functional.impl that return CloseableIterator

Modifier and Type	Method	Description
static <T> CloseableIterator<T>	Traversables.asIterator(Traversable<T> traversable)

Uses of CloseableIterator in org.infinispan.persistence.sifs

Methods in org.infinispan.persistence.sifs that return CloseableIterator

Modifier and Type	Method	Description
CloseableIterator<Integer>	FileProvider.getFileIterator()

Uses of CloseableIterator in org.infinispan.query.dsl

Methods in org.infinispan.query.dsl that return CloseableIterator

Modifier and Type	Method	Description
<K> CloseableIterator<Map.Entry<K,T>>	Query.entryIterator()	Returns a CloseableIterator over the results, including both key and value.
CloseableIterator<T>	Query.iterator()	Returns a CloseableIterator over the results.

Uses of CloseableIterator in org.infinispan.query.impl

Classes in org.infinispan.query.impl that implement CloseableIterator

Modifier and Type	Class	Description
class	ScrollerIteratorAdaptor<E>	Adaptor to use a link SearchScroll as an iterator.

Methods in org.infinispan.query.impl that return CloseableIterator

Modifier and Type	Method	Description
<K> CloseableIterator<Map.Entry<K,E>>	IndexedQuery.entryIterator()	Returns the matching entries (both key and value).
<K> CloseableIterator<Map.Entry<K,E>>	IndexedQueryImpl.entryIterator()
CloseableIterator<E>	IndexedQuery.iterator()
CloseableIterator<E>	IndexedQueryImpl.iterator()

Uses of CloseableIterator in org.infinispan.server.hotrod

Methods in org.infinispan.server.hotrod with parameters of type CloseableIterator

Modifier and Type	Method	Description
io.netty.buffer.ByteBuf	VersionedEncoder.bulkGetKeysResponse(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, CloseableIterator<byte[]> iterator)

Uses of CloseableIterator in org.infinispan.stream.impl

Classes in org.infinispan.stream.impl that implement CloseableIterator

Modifier and Type	Class	Description
class	RemovableCloseableIterator<K,C>	Deprecated. Users should use RemovableCloseableIterator instead

Constructors in org.infinispan.stream.impl with parameters of type CloseableIterator

Modifier	Constructor	Description
	RemovableCloseableIterator(CloseableIterator<C> realIterator, Cache<K,?> cache, Function<? super C,K> removeFunction)	Deprecated.

Uses of CloseableIterator in org.infinispan.util

Classes in org.infinispan.util that implement CloseableIterator

Modifier and Type	Class	Description
class	CloseableSuppliedIterator<E>
class	LazyConcatIterator<E>	Iterator implementation that will return all entries from the first iterator.

Methods in org.infinispan.util that return CloseableIterator

Modifier and Type	Method	Description
CloseableIterator<R>	CacheSetMapper.iterator()
static <E> CloseableIterator<E>	Closeables.iterator(org.reactivestreams.Publisher<E> publisher, int fetchSize)	Deprecated, for removal: This API element is subject to removal in a future version. since 11.0 Please use Closeables.iterator(Publisher, int) instead.
CloseableIterator<R>	WriteableCacheCollectionMapper.iterator()

Constructors in org.infinispan.util with parameters of type CloseableIterator

Modifier	Constructor	Description
	LazyConcatIterator(CloseableIterator<E> first, Supplier<? extends CloseableIterator<E>> supplier)

Constructor parameters in org.infinispan.util with type arguments of type CloseableIterator

Modifier	Constructor	Description
	LazyConcatIterator(CloseableIterator<E> first, Supplier<? extends CloseableIterator<E>> supplier)