Uses of Interface
org.infinispan.commons.util.CloseableIterator
Packages that use CloseableIterator
Package
Description
Hot Rod client API.
Commons package providing various utility classes
Query module internals.
-
Uses of CloseableIterator in org.infinispan.client.hotrod
Methods in org.infinispan.client.hotrod that return CloseableIteratorModifier 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
Methods in org.infinispan.client.hotrod.impl that return CloseableIteratorModifier 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.client.hotrod.impl.protocol
Methods in org.infinispan.client.hotrod.impl.protocol that return CloseableIteratorModifier and TypeMethodDescriptionprotected <K,V> CloseableIterator<Map.Entry<K, V>> Codec23.castEntryIterator(CloseableIterator iterator) default <K,V> CloseableIterator<Map.Entry<K, V>> Codec.entryIterator(RemoteCache<K, V> remoteCache, IntSet segments, int batchSize) Creates an entry iterator with the given batch size if applicable.<K,V> CloseableIterator<Map.Entry<K, V>> Codec23.entryIterator(RemoteCache<K, V> remoteCache, IntSet segments, int batchSize) default <K> CloseableIterator<K>Codec.keyIterator(RemoteCache<K, ?> remoteCache, OperationsFactory operationsFactory, IntSet segments, int batchSize) Creates a key iterator with the given batch size if applicable.<K> CloseableIterator<K>Codec20.keyIterator(RemoteCache<K, ?> remoteCache, OperationsFactory operationsFactory, IntSet segments, int batchSize) <K> CloseableIterator<K>Codec23.keyIterator(RemoteCache<K, ?> remoteCache, OperationsFactory operationsFactory, IntSet segments, int batchSize) <K> CloseableIterator<K>Codec27.keyIterator(RemoteCache<K, ?> remoteCache, OperationsFactory operationsFactory, IntSet segments, int batchSize) Methods in org.infinispan.client.hotrod.impl.protocol with parameters of type CloseableIteratorModifier and TypeMethodDescriptionprotected <K,V> CloseableIterator<Map.Entry<K, V>> Codec23.castEntryIterator(CloseableIterator iterator) -
Uses of CloseableIterator in org.infinispan.client.hotrod.impl.query
Methods in org.infinispan.client.hotrod.impl.query that return CloseableIterator -
Uses of CloseableIterator in org.infinispan.commons.api.query
Subinterfaces of CloseableIterator in org.infinispan.commons.api.queryMethods in org.infinispan.commons.api.query that return CloseableIterator -
Uses of CloseableIterator in org.infinispan.commons.util
Classes in org.infinispan.commons.util that implement CloseableIteratorModifier and TypeClassDescriptionclassIterator that concatenates a bunch of iterables into 1 big iterator.classIterator that also filters out entries based on the provided predicate.classIteratorMapper<E,S> A iterator that maps each value to the output of the Function.classA 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 CloseableIteratorModifier and TypeFieldDescriptionprotected final CloseableIterator<C>RemovableCloseableIterator.realIteratorMethods in org.infinispan.commons.util that return CloseableIteratorModifier 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 aPublisherto aCloseableIteratorby 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 CloseableIteratorModifier 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 iteratorConstructors in org.infinispan.commons.util with parameters of type CloseableIteratorModifierConstructorDescriptionRemovableCloseableIterator(CloseableIterator<C> realIterator, Consumer<? super C> consumer) -
Uses of CloseableIterator in org.infinispan.query.clustered
Classes in org.infinispan.query.clustered that implement CloseableIteratorMethods in org.infinispan.query.clustered that return CloseableIterator -
Uses of CloseableIterator in org.infinispan.query.impl
Classes in org.infinispan.query.impl that implement CloseableIteratorMethods in org.infinispan.query.impl that return CloseableIterator