Uses of Interface
org.infinispan.commons.util.CloseableIterator
Package
Description
This is the core of Infinispan, a distributed, transactional, highly scalable data grid
platform.
Hot Rod client API.
Commons package providing various utility classes
Soft Index
NonBlockingStore
.Query module internals.
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
-
Uses of CloseableIterator in org.infinispan.cache.impl
-
Uses of CloseableIterator in org.infinispan.client.hotrod
Modifier and TypeMethodDescriptiondefault CloseableIterator
<Map.Entry<Object, Object>> RemoteCache.retrieveEntries
(String filterConverterFactory, int batchSize) 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) RemoteCache.retrieveEntriesByQuery
(Query<?> filterQuery, Set<Integer> segments, int batchSize) Retrieve entries from the server matching a query.RemoteCache.retrieveEntriesWithMetadata
(Set<Integer> segments, int batchSize) Retrieve entries with metadata information -
Uses of CloseableIterator in org.infinispan.client.hotrod.impl
Modifier and TypeMethodDescriptionDelegatingRemoteCache.entryIterator
(IntSet segments) InternalRemoteCache.entryIterator
(IntSet segments) RemoteCacheImpl.entryIterator
(IntSet segments) DelegatingRemoteCache.keyIterator
(IntSet segments) InternalRemoteCache.keyIterator
(IntSet segments) RemoteCacheImpl.keyIterator
(IntSet segments) DelegatingRemoteCache.retrieveEntries
(String filterConverterFactory, Object[] filterConverterParams, Set<Integer> segments, int batchSize) RemoteCacheImpl.retrieveEntries
(String filterConverterFactory, Object[] filterConverterParams, Set<Integer> segments, int batchSize) DelegatingRemoteCache.retrieveEntriesByQuery
(Query<?> filterQuery, Set<Integer> segments, int batchSize) RemoteCacheImpl.retrieveEntriesByQuery
(Query<?> filterQuery, Set<Integer> segments, int batchSize) DelegatingRemoteCache.retrieveEntriesWithMetadata
(Set<Integer> segments, int batchSize) RemoteCacheImpl.retrieveEntriesWithMetadata
(Set<Integer> segments, int batchSize) -
Uses of CloseableIterator in org.infinispan.commons.api.query
-
Uses of CloseableIterator in org.infinispan.commons.util
Modifier and TypeClassDescriptionclass
Iterator that concatenates a bunch of iterables into 1 big iterator.class
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
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.Modifier and TypeFieldDescriptionprotected final CloseableIterator
<C> RemovableCloseableIterator.realIterator
Modifier and TypeMethodDescriptionCloseableIterable.iterator()
CloseableIteratorCollection.iterator()
CloseableIteratorCollectionAdapter.iterator()
static <E> CloseableIterator
<E> 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 wellstatic <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.Modifier and TypeMethodDescriptionstatic <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 iteratorModifierConstructorDescriptionRemovableCloseableIterator
(CloseableIterator<C> realIterator, Consumer<? super C> consumer) -
Uses of CloseableIterator in org.infinispan.functional.impl
Modifier and TypeMethodDescriptionstatic <T> CloseableIterator
<T> Traversables.asIterator
(Traversable<T> traversable) -
Uses of CloseableIterator in org.infinispan.persistence.sifs
-
Uses of CloseableIterator in org.infinispan.query.impl
Modifier and TypeClassDescriptionclass
Adaptor to use a linkSearchScroll
as an iterator. -
Uses of CloseableIterator in org.infinispan.server.hotrod
Modifier and TypeMethodDescriptionio.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
ModifierConstructorDescriptionRemovableCloseableIterator
(CloseableIterator<C> realIterator, Cache<K, ?> cache, Function<? super C, K> removeFunction) Deprecated. -
Uses of CloseableIterator in org.infinispan.util
Modifier and TypeClassDescriptionclass
class
Iterator implementation that will return all entries from the first iterator.Modifier and TypeMethodDescriptionCacheSetMapper.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 useCloseables.iterator(Publisher, int)
instead.WriteableCacheCollectionMapper.iterator()
ModifierConstructorDescriptionLazyConcatIterator
(CloseableIterator<E> first, Supplier<? extends CloseableIterator<E>> supplier) ModifierConstructorDescriptionLazyConcatIterator
(CloseableIterator<E> first, Supplier<? extends CloseableIterator<E>> supplier)
RemovableCloseableIterator
instead