Uses of Interface
org.infinispan.CacheSet
Package
Description
This is the core of Infinispan, a distributed, transactional, highly scalable data grid
platform.
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 CacheSet in org.infinispan
Modifier and TypeClassDescriptionclass
Base class for internal classes used in cache collections.Modifier and TypeMethodDescriptionCacheSet
<CacheEntry<K, V>> AdvancedCache.cacheEntrySet()
Identical toCache.entrySet()
but is typed to return CacheEntries instead of Entries.Cache.entrySet()
Returns a set view of the mappings contained in this cache and cache loader across the entire cluster.Cache.keySet()
Returns a set view of the keys contained in this cache and cache loader across the entire cluster. -
Uses of CacheSet in org.infinispan.cache.impl
Modifier and TypeClassDescriptionclass
AbstractCacheBackedSet<K,
V, E> Entry or key set backed by a cache.class
CacheBackedEntrySet<K,
V> Entry set backed by a cache.class
CacheBackedKeySet<K,
V> Key set backed by a cache.protected class
protected class
protected class
SimpleCacheImpl.EntrySetBase<T extends Map.Entry<K,
V>> protected class
Modifier and TypeMethodDescriptionCacheSet
<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()
AbstractDelegatingCache.entrySet()
CacheImpl.entrySet()
DecoratedCache.entrySet()
EncoderCache.entrySet()
SimpleCacheImpl.entrySet()
AbstractDelegatingCache.keySet()
CacheImpl.keySet()
DecoratedCache.keySet()
EncoderCache.keySet()
SimpleCacheImpl.keySet()
-
Uses of CacheSet in org.infinispan.reactive.publisher.impl
Modifier and TypeMethodDescriptionprotected <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, LocalPublisherManagerImpl<K, V>.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> LocalPublisherManagerImpl.exactlyOnceSequential
(CacheSet<I> set, Set<K> keysToExclude, Function<I, K> toKeyFunction, IntSet segments, Function<? super org.reactivestreams.Publisher<I>, ? extends CompletionStage<R>> collator, LocalPublisherManagerImpl<K, V>.org.infinispan.reactive.publisher.impl.LocalPublisherManagerImpl.SegmentListener listener, IntSet concurrentSegments) -
Uses of CacheSet in org.infinispan.security.impl
-
Uses of CacheSet in org.infinispan.server.hotrod
Modifier and TypeMethodDescriptionio.netty.buffer.ByteBuf
VersionedEncoder.bulkGetResponse
(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, int size, CacheSet<Map.Entry<byte[], byte[]>> entries) -
Uses of CacheSet in org.infinispan.util
Modifier and TypeClassDescriptionclass
CacheSetMapper<E,
R> ACacheSet
that allows for a different set to be mapped as a different instance wtih values replaced on request.class
A writeable cache set mapper that also has constant time operations for things such asCollection.contains(Object)
if the underlying Set does.ModifierConstructorDescriptionWriteableCacheSetMapper
(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)