| Package | Description |
|---|---|
| org.infinispan.cache.impl | |
| org.infinispan.client.hotrod |
Hot Rod client API.
|
| org.infinispan.client.hotrod.impl | |
| org.infinispan.client.hotrod.impl.protocol | |
| org.infinispan.client.hotrod.impl.query | |
| org.infinispan.commands.read | |
| org.infinispan.commons.util |
Commons package providing various utility classes
|
| org.infinispan.functional.impl | |
| org.infinispan.interceptors.distribution |
Interceptors dealing with command replication in distributed/replicated mode.
|
| 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 | 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() |
| Modifier and Type | Method and 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(org.infinispan.query.dsl.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<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(org.infinispan.query.dsl.Query<?> filterQuery,
Set<Integer> segments,
int batchSize) |
CloseableIterator<Map.Entry<Object,Object>> |
RemoteCacheImpl.retrieveEntriesByQuery(org.infinispan.query.dsl.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) |
| Modifier and Type | Method and Description |
|---|---|
protected <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) |
| Modifier and Type | Method and Description |
|---|---|
protected <K,V> CloseableIterator<Map.Entry<K,V>> |
Codec23.castEntryIterator(CloseableIterator iterator) |
| Modifier and Type | Method and Description |
|---|---|
CloseableIterator<T> |
RemoteQuery.iterator() |
| Modifier and Type | Method and Description |
|---|---|
abstract CloseableIterator<O> |
AbstractCloseableIteratorCollection.iterator() |
| Modifier and Type | Field and Description |
|---|---|
protected CloseableIterator<C> |
RemovableCloseableIterator.realIterator |
| Modifier and Type | Method and Description |
|---|---|
CloseableIterator<E> |
CloseableIterable.iterator() |
CloseableIterator<E> |
CloseableIteratorCollection.iterator() |
CloseableIterator<E> |
CloseableIteratorCollectionAdapter.iterator() |
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(Iterator<? extends E> iterator)
Creates a closeable iterator from the given iterator that does nothing when close is called.
|
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. |
| 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.
|
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
|
| Constructor and Description |
|---|
RemovableCloseableIterator(CloseableIterator<C> realIterator,
Consumer<? super C> consumer) |
| 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() |
| Constructor and Description |
|---|
RemovableCloseableIterator(CloseableIterator<C> realIterator,
Cache<K,?> cache,
Function<? super C,K> removeFunction)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
CloseableIterator<V> |
ValueCacheCollection.iterator() |
| Constructor and Description |
|---|
Builder(CloseableIterator<? extends T> closeableIterator) |
| Modifier and Type | Method and Description |
|---|---|
CloseableIterator<E> |
AbstractDelegatingCloseableIteratorCollection.iterator() |
CloseableIterator<E> |
AbstractDelegatingCloseableIteratorSet.iterator() |
CloseableIterator<R> |
CacheSetMapper.iterator() |
CloseableIterator<R> |
WriteableCacheCollectionMapper.iterator() |
static <E> CloseableIterator<E> |
Closeables.iterator(org.reactivestreams.Publisher<E> publisher,
int fetchSize)
Deprecated.
since 11.0 Please use
Closeables.iterator(Publisher, int) instead. |
| Constructor and Description |
|---|
LazyConcatIterator(CloseableIterator<E> first,
Supplier<? extends CloseableIterator<E>> supplier) |
| Constructor and Description |
|---|
LazyConcatIterator(CloseableIterator<E> first,
Supplier<? extends CloseableIterator<E>> supplier) |
Copyright © 2022 JBoss by Red Hat. All rights reserved.