| Package | Description |
|---|---|
| org.infinispan |
This is the core of Infinispan, a distributed, transactional, highly scalable data grid
platform.
|
| org.infinispan.cache.impl | |
| org.infinispan.interceptors.distribution |
Interceptors dealing with command replication in distributed/replicated mode.
|
| org.infinispan.reactive.publisher.impl | |
| org.infinispan.security.impl | |
| org.infinispan.stream.impl.interceptor | |
| org.infinispan.stream.impl.local | |
| 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 |
|---|---|
CacheSet<CacheEntry<K,V>> |
AdvancedCache.cacheEntrySet()
Identical to
Cache.entrySet() but is typed to return CacheEntries instead of Entries. |
CacheSet<Map.Entry<K,V>> |
Cache.entrySet()
Returns a set view of the mappings contained in this cache and cache loader across the entire cluster.
|
CacheSet<K> |
Cache.keySet()
Returns a set view of the keys contained in this cache and cache loader across the entire cluster.
|
| Modifier and Type | Class and Description |
|---|---|
protected class |
SimpleCacheImpl.CacheEntrySet |
protected class |
SimpleCacheImpl.EntrySet |
protected class |
SimpleCacheImpl.EntrySetBase<T extends Map.Entry<K,V>> |
protected class |
SimpleCacheImpl.KeySet |
| Modifier and Type | Method and Description |
|---|---|
CacheSet<CacheEntry<K,V>> |
AbstractDelegatingAdvancedCache.cacheEntrySet() |
CacheSet<CacheEntry<K,V>> |
CacheImpl.cacheEntrySet() |
CacheSet<CacheEntry<K,V>> |
DecoratedCache.cacheEntrySet() |
CacheSet<CacheEntry<K,V>> |
EncoderCache.cacheEntrySet() |
CacheSet<CacheEntry<K,V>> |
SimpleCacheImpl.cacheEntrySet() |
CacheSet<Map.Entry<K,V>> |
AbstractDelegatingCache.entrySet() |
CacheSet<Map.Entry<K,V>> |
CacheImpl.entrySet() |
CacheSet<Map.Entry<K,V>> |
DecoratedCache.entrySet() |
CacheSet<Map.Entry<K,V>> |
EncoderCache.entrySet() |
CacheSet<Map.Entry<K,V>> |
SimpleCacheImpl.entrySet() |
CacheSet<K> |
AbstractDelegatingCache.keySet() |
CacheSet<K> |
CacheImpl.keySet() |
CacheSet<K> |
DecoratedCache.keySet() |
CacheSet<K> |
EncoderCache.keySet() |
CacheSet<K> |
SimpleCacheImpl.keySet() |
| Modifier and Type | Class and Description |
|---|---|
protected static class |
DistributionBulkInterceptor.BackingEntrySet<K,V> |
protected static class |
DistributionBulkInterceptor.BackingKeySet<K,V> |
protected static class |
DistributionBulkInterceptor.TxBackingEntrySet<K,V> |
| Modifier and Type | Field and Description |
|---|---|
protected CacheSet<CacheEntry<K,V>> |
DistributionBulkInterceptor.BackingEntrySet.entrySet |
protected CacheSet<K> |
DistributionBulkInterceptor.BackingKeySet.keySet |
| Constructor and Description |
|---|
BackingKeySet(Cache<K,V> cache,
CacheSet<K> keySet,
FlagAffectedCommand command) |
| Modifier and Type | Field and Description |
|---|---|
protected CacheSet<CacheEntry<K,V>> |
LocalPublisherManagerImpl.entrySet |
protected CacheSet<CacheEntry<K,V>> |
LocalPublisherManagerImpl.entrySetWithoutLoader |
protected CacheSet<K> |
LocalPublisherManagerImpl.keySet |
protected CacheSet<K> |
LocalPublisherManagerImpl.keySetWithoutLoader |
| Modifier and Type | Method and Description |
|---|---|
protected <I,R> io.reactivex.rxjava3.core.Flowable<R> |
LocalPublisherManagerImpl.exactlyOnceParallel(CacheSet<I> set,
Set<K> keysToExclude,
Function<I,K> toKeyFunction,
IntSet segments,
Function<? super org.reactivestreams.Publisher<I>,? extends CompletionStage<R>> collator,
org.infinispan.reactive.publisher.impl.LocalPublisherManagerImpl.SegmentListener listener,
IntSet concurrentSegments)
This method iteratively submits a task to operate on the cpu bound thread pool up to the number of cores - 1.
|
protected <I,R> io.reactivex.rxjava3.core.Flowable<R> |
NonSegmentedLocalPublisherManagerImpl.exactlyOnceParallel(CacheSet<I> set,
Set<K> keysToExclude,
Function<I,K> toKeyFunction,
IntSet segments,
Function<? super org.reactivestreams.Publisher<I>,? extends CompletionStage<R>> transformer,
org.infinispan.reactive.publisher.impl.LocalPublisherManagerImpl.SegmentListener listener,
IntSet concurrentSegments) |
protected <I,R> io.reactivex.rxjava3.core.Flowable<R> |
LocalPublisherManagerImpl.exactlyOnceSequential(CacheSet<I> set,
Set<K> keysToExclude,
Function<I,K> toKeyFunction,
IntSet segments,
Function<? super org.reactivestreams.Publisher<I>,? extends CompletionStage<R>> collator,
org.infinispan.reactive.publisher.impl.LocalPublisherManagerImpl.SegmentListener listener,
IntSet concurrentSegments) |
protected <I,R> io.reactivex.rxjava3.core.Flowable<R> |
NonSegmentedLocalPublisherManagerImpl.exactlyOnceSequential(CacheSet<I> set,
Set<K> keysToExclude,
Function<I,K> toKeyFunction,
IntSet segments,
Function<? super org.reactivestreams.Publisher<I>,? extends CompletionStage<R>> transformer,
org.infinispan.reactive.publisher.impl.LocalPublisherManagerImpl.SegmentListener listener,
IntSet concurrentSegments) |
| Modifier and Type | Method and Description |
|---|---|
CacheSet<CacheEntry<K,V>> |
SecureCacheImpl.cacheEntrySet() |
CacheSet<Map.Entry<K,V>> |
SecureCacheImpl.entrySet() |
CacheSet<K> |
SecureCacheImpl.keySet() |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractDelegatingEntryCacheSet<K,V>
Abstract cache entry set that delegates to the underlying cache for stream usage
|
class |
AbstractDelegatingKeyCacheSet<K,V>
Abstract cache key set that delegates to the underlying cache for stream usage
|
| Modifier and Type | Method and Description |
|---|---|
protected CacheSet<K> |
AbstractDelegatingKeyCacheSet.delegate() |
protected CacheSet<CacheEntry<K,V>> |
AbstractDelegatingEntryCacheSet.delegate() |
| Constructor and Description |
|---|
AbstractDelegatingEntryCacheSet(Cache<K,V> cache,
CacheSet<CacheEntry<K,V>> set) |
AbstractDelegatingKeyCacheSet(Cache<K,V> cache,
CacheSet<K> set) |
| Constructor and Description |
|---|
ValueCacheCollection(Cache<K,V> cache,
CacheSet<CacheEntry<K,V>> cacheSet) |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractDelegatingCacheSet<E>
Same as
AbstractDelegatingCacheCollection except this method implements Set as well. |
class |
CacheSetMapper<E,R>
A
CacheSet that allows for a different set to be mapped as a different instance wtih values replaced on
request. |
class |
WriteableCacheSetMapper<E,R>
A writeable cache set mapper that also has constant time operations for things such as
Collection.contains(Object) if the underlying Set does. |
| Modifier and Type | Field and Description |
|---|---|
protected CacheSet<E> |
CacheSetMapper.realSet |
| Modifier and Type | Method and Description |
|---|---|
protected abstract CacheSet<E> |
AbstractDelegatingCacheSet.delegate() |
| Constructor and Description |
|---|
CacheSetMapper(CacheSet<E> realSet,
Function<? super E,? extends R> mapper) |
WriteableCacheSetMapper(CacheSet<E> realSet,
InjectiveFunction<? super E,? extends R> toNewTypeFunction,
InjectiveFunction<? super E,? extends R> toNewTypeIteratorFunction,
InjectiveFunction<? super R,? extends E> fromNewTypeFunction,
InjectiveFunction<Object,?> keyFilterFunction) |
WriteableCacheSetMapper(CacheSet<E> realSet,
InjectiveFunction<? super E,? extends R> toNewTypeFunction,
InjectiveFunction<? super R,? extends E> fromNewTypeFunction,
InjectiveFunction<Object,?> keyFilterFunction) |
Copyright © 2022 JBoss by Red Hat. All rights reserved.