Uses of Interface
org.infinispan.commons.util.CloseableIterator
-
Packages that use CloseableIterator Package Description 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 classesorg.infinispan.functional.impl org.infinispan.interceptors.distribution Interceptors dealing with command replication in distributed/replicated mode.org.infinispan.persistence.sifs Soft IndexAdvancedLoadWriteStore
.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.cache.impl
Methods in org.infinispan.cache.impl that return CloseableIterator Modifier and Type Method Description 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 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 serverCloseableIterator<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<Object,Object>>
RemoteCacheImpl. retrieveEntries(String filterConverterFactory, int batchSize)
CloseableIterator<Map.Entry<Object,Object>>
RemoteCacheImpl. retrieveEntries(String filterConverterFactory, Object[] filterConverterParams, Set<Integer> segments, int batchSize)
CloseableIterator<Map.Entry<Object,Object>>
RemoteCacheImpl. retrieveEntries(String filterConverterFactory, 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>>>
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
CloseableIteratorMapper<E,S>
Deprecated.since 9.3 users can just useIteratorMapper
as it handles CloseableIterators nowclass
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 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 wellMethods 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 iteratorConstructors in org.infinispan.commons.util with parameters of type CloseableIterator 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.interceptors.distribution
Methods in org.infinispan.interceptors.distribution that return CloseableIterator Modifier and Type Method Description CloseableIterator<CacheEntry<K,V>>
DistributionBulkInterceptor.BackingEntrySet. iterator()
CloseableIterator<K>
DistributionBulkInterceptor.BackingKeySet. iterator()
-
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.server.hotrod
Methods in org.infinispan.server.hotrod with parameters of type CloseableIterator Modifier and Type Method Description io.netty.buffer.ByteBuf
AbstractEncoder1x. bulkGetKeysResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, CloseableIterator<byte[]> iterator)
io.netty.buffer.ByteBuf
VersionedEncoder. bulkGetKeysResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, CloseableIterator<byte[]> iterator)
-
Uses of CloseableIterator in org.infinispan.stream.impl
Subinterfaces of CloseableIterator in org.infinispan.stream.impl Modifier and Type Interface Description static interface
IteratorHandler.OnCloseIterator<E>
ACloseableIterator
that also allows callers to attachRunnable
instances to it, so that when this iterator is closed, those Runnables are also invoked.Classes in org.infinispan.stream.impl that implement CloseableIterator Modifier and Type Class Description class
RemovableCloseableIterator<K,C>
Deprecated.Users should useRemovableCloseableIterator
insteadMethods in org.infinispan.stream.impl that return CloseableIterator Modifier and Type Method Description <E> CloseableIterator<E>
IteratorHandler. getIterator(Object requestId)
CloseableIterator<T>
PriorityMergingProcessor. iterator()
Constructors in org.infinispan.stream.impl with parameters of type CloseableIterator 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<E>
AbstractDelegatingCloseableIteratorCollection. iterator()
CloseableIterator<E>
AbstractDelegatingCloseableIteratorSet. iterator()
CloseableIterator<R>
CacheCollectionMapper. iterator()
Deprecated.CloseableIterator<R>
CacheSetMapper. iterator()
static <E> CloseableIterator<E>
Closeables. iterator(org.reactivestreams.Publisher<E> publisher, int fetchSize)
Converts aPublisher
to aCloseableIterator
by utilizing items fetched into an array and refetched as they are consumed from the iterator.CloseableIterator<R>
WriteableCacheCollectionMapper. iterator()
Constructors in org.infinispan.util with parameters of type CloseableIterator Constructor Description LazyConcatIterator(CloseableIterator<E> first, Supplier<? extends CloseableIterator<E>> supplier)
Constructor parameters in org.infinispan.util with type arguments of type CloseableIterator Constructor Description LazyConcatIterator(CloseableIterator<E> first, Supplier<? extends CloseableIterator<E>> supplier)
-