Package | Description |
---|---|
org.infinispan.cache.impl | |
org.infinispan.client.hotrod |
HotRod Client API
|
org.infinispan.client.hotrod.impl | |
org.infinispan.client.hotrod.impl.iteration | |
org.infinispan.commands.read | |
org.infinispan.commons.util |
Commons package providing various utility classes
|
org.infinispan.functional.impl | |
org.infinispan.interceptors.distribution | |
org.infinispan.iteration.impl |
Provides Infinispan-specific implementation details iterating over entries in the cache, specifically optimized for
distributed caches.
|
org.infinispan.stream.impl | |
org.infinispan.stream.impl.local | |
org.infinispan.stream.impl.spliterators | |
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.
|
Modifier and Type | Class and Description |
---|---|
protected class |
SimpleCacheImpl.ConvertingIterator<C> |
protected class |
SimpleCacheImpl.FilteringIterator |
Modifier and Type | Method and Description |
---|---|
CloseableIterator<Map.Entry<K,V>> |
SimpleCacheImpl.EntrySet.iterator() |
CloseableIterator<CacheEntry<K,V>> |
SimpleCacheImpl.CacheEntrySet.iterator() |
CloseableIterator<V> |
SimpleCacheImpl.Values.iterator() |
CloseableIterator<K> |
SimpleCacheImpl.KeySet.iterator() |
CloseableIterator<CacheEntry<K,V>> |
SimpleCacheImpl.FilteredEntryIterable.iterator() |
CloseableIterator<CacheEntry<K,C>> |
SimpleCacheImpl.ConvertedIterable.iterator() |
Modifier and Type | Method and 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 server
|
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
|
Modifier and Type | Method and 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) |
Modifier and Type | Class and Description |
---|---|
class |
RemoteCloseableIterator<E> |
Modifier and Type | Method and Description |
---|---|
abstract CloseableIterator<O> |
AbstractCloseableIteratorCollection.iterator() |
Modifier and Type | Class and Description |
---|---|
class |
CloseableIteratorMapper<E,S>
A iterator that maps each value to the output of the Function.
|
Modifier and Type | Method and Description |
---|---|
CloseableIterator<E> |
CloseableIteratorCollectionAdapter.iterator() |
CloseableIterator<E> |
CloseableIteratorCollection.iterator() |
CloseableIterator<E> |
CloseableIterable.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(Stream<? extends R> stream)
Creates a closeable iterator that when closed will close the underlying stream as well
|
Modifier and Type | Method and 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.
|
Constructor and Description |
---|
CloseableIteratorMapper(CloseableIterator<? extends E> iterator,
Function<? super E,? extends S> function) |
Modifier and Type | Method and Description |
---|---|
static <T> CloseableIterator<T> |
Traversables.asIterator(Traversable<T> traversable) |
Modifier and Type | Method and Description |
---|---|
CloseableIterator<CacheEntry<K,V>> |
DistributionBulkInterceptor.BackingEntrySet.iterator() |
CloseableIterator<K> |
DistributionBulkInterceptor.BackingKeySet.iterator() |
Modifier and Type | Class and Description |
---|---|
protected class |
DistributedEntryRetriever.DistributedItr<C> |
protected class |
LocalEntryRetriever.DataContainerIterator<C> |
protected class |
LocalEntryRetriever.Itr<C> |
class |
RemovableEntryIterator<K,V,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 cache to remove the previously read value.
|
class |
TransactionAwareCloseableIterator<K,V,C>
Class that provides transactional support so that the iterator will use the values in the context if they exist.
|
Modifier and Type | Field and Description |
---|---|
protected CloseableIterator<CacheEntry<K,V>> |
RemovableEntryIterator.realIterator |
Modifier and Type | Method and Description |
---|---|
CloseableIterator<CacheEntry<K,C>> |
TrackingEntryIterableFromStream.iterator() |
CloseableIterator<CacheEntry<K,C>> |
TransactionAwareCloseableIterable.iterator() |
<C> CloseableIterator<CacheEntry<K,C>> |
EntryRetriever.retrieveEntries(KeyValueFilter<? super K,? super V> filter,
Converter<? super K,? super V,? extends C> converter,
Set<Flag> flags,
EntryRetriever.SegmentListener listener)
Deprecated.
This is invoked locally on the node that requested the iteration process.
|
<C> CloseableIterator<CacheEntry<K,C>> |
LocalEntryRetriever.retrieveEntries(KeyValueFilter<? super K,? super V> filter,
Converter<? super K,? super V,? extends C> converter,
Set<Flag> flags,
EntryRetriever.SegmentListener listener) |
<C> CloseableIterator<CacheEntry<K,C>> |
DistributedEntryRetriever.retrieveEntries(KeyValueFilter<? super K,? super V> filter,
Converter<? super K,? super V,? extends C> converter,
Set<Flag> flags,
EntryRetriever.SegmentListener listener) |
Constructor and Description |
---|
RemovableEntryIterator(CloseableIterator<CacheEntry<K,V>> realIterator,
Cache<K,V> cache,
boolean initIterator) |
TransactionAwareCloseableIterator(CloseableIterator<CacheEntry<K,V>> realIterator,
KeyValueFilter<? super K,? super V> filter,
Converter<? super K,? super V,? extends C> converter,
TxInvocationContext<LocalTransaction> ctx,
Cache<K,V> cache) |
Modifier and Type | Class and Description |
---|---|
class |
RemovableCloseableIterator<K,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 cache to remove the previously read value.
|
Modifier and Type | Field and Description |
---|---|
protected CloseableIterator<C> |
RemovableCloseableIterator.realIterator |
Constructor and Description |
---|
RemovableCloseableIterator(CloseableIterator<C> realIterator,
Cache<K,?> cache,
Function<? super C,K> removeFunction) |
Modifier and Type | Method and Description |
---|---|
CloseableIterator<R> |
LocalCacheStream.iterator() |
CloseableIterator<V> |
ValueCacheCollection.iterator() |
CloseableIterator<CacheEntry<K,V>> |
EntryStreamSupplier.removableIterator(CloseableIterator<CacheEntry<K,V>> realIterator) |
CloseableIterator<K> |
KeyStreamSupplier.removableIterator(CloseableIterator<K> realIterator) |
CloseableIterator<R> |
AbstractLocalCacheStream.StreamSupplier.removableIterator(CloseableIterator<R> realIterator) |
Modifier and Type | Method and Description |
---|---|
CloseableIterator<CacheEntry<K,V>> |
EntryStreamSupplier.removableIterator(CloseableIterator<CacheEntry<K,V>> realIterator) |
CloseableIterator<K> |
KeyStreamSupplier.removableIterator(CloseableIterator<K> realIterator) |
CloseableIterator<R> |
AbstractLocalCacheStream.StreamSupplier.removableIterator(CloseableIterator<R> realIterator) |
Constructor and Description |
---|
Builder(CloseableIterator<? extends T> closeableIterator) |
Modifier and Type | Class and Description |
---|---|
class |
CloseableSuppliedIterator<E> |
class |
DistinctKeyDoubleEntryCloseableIterator<E,K> |
Modifier and Type | Method and Description |
---|---|
CloseableIterator<E> |
AbstractDelegatingCloseableIteratorCollection.iterator() |
CloseableIterator<E> |
AbstractDelegatingCloseableIteratorSet.iterator() |
Constructor and Description |
---|
DistinctKeyDoubleEntryCloseableIterator(CloseableIterator<E> first,
CloseableIterator<E> second,
Function<? super E,K> function,
Set<K> seenKeys) |
DistinctKeyDoubleEntryCloseableIterator(CloseableIterator<E> first,
CloseableIterator<E> second,
Function<? super E,K> function,
Set<K> seenKeys) |
Copyright © 2023 JBoss, a division of Red Hat. All rights reserved.