Package | Description |
---|---|
org.infinispan |
This is the core of Infinispan, a distributed, transactional, highly scalable data grid
platform.
|
org.infinispan.cache.impl | |
org.infinispan.filter |
Provides capabilities around filtering and converting entries that are found in the cache or cache store/loader.
|
org.infinispan.interceptors.distribution |
Interceptors dealing with command replication in distributed/replicated mode.
|
org.infinispan.stream.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 |
---|---|
CacheStream<Double> |
DoubleCacheStream.boxed() |
CacheStream<Integer> |
IntCacheStream.boxed() |
CacheStream<Long> |
LongCacheStream.boxed() |
CacheStream<R> |
CacheStream.disableRehashAware()
Disables tracking of rehash events that could occur to the underlying cache.
|
CacheStream<R> |
CacheStream.distinct() |
CacheStream<R> |
CacheStream.distributedBatchSize(int batchSize)
Controls how many keys are returned from a remote node when using a stream terminal operation with a distributed
cache to back this stream.
|
CacheStream<R> |
CacheStream.filter(Predicate<? super R> predicate) |
default CacheStream<R> |
CacheStream.filter(SerializablePredicate<? super R> predicate)
Same as
filter(Predicate) except that the Predicate must also
implement Serializable |
CacheStream<R> |
CacheStream.filterKeys(Set<?> keys)
Filters which entries are returned by only returning ones that map to the given key.
|
CacheStream<R> |
CacheStream.filterKeySegments(IntSet segments)
Filters which entries are returned by what segment they are present in.
|
CacheStream<R> |
CacheStream.filterKeySegments(Set<Integer> segments)
Deprecated.
This is to be replaced by
filterKeySegments(IntSet) |
<R1> CacheStream<R1> |
CacheStream.flatMap(Function<? super R,? extends Stream<? extends R1>> mapper) |
default <R1> CacheStream<R1> |
CacheStream.flatMap(SerializableFunction<? super R,? extends Stream<? extends R1>> mapper)
Same as
flatMap(Function) except that the Function must also
implement Serializable |
CacheStream<R> |
CacheStream.limit(long maxSize) |
<R1> CacheStream<R1> |
CacheStream.map(Function<? super R,? extends R1> mapper) |
default <R1> CacheStream<R1> |
CacheStream.map(SerializableFunction<? super R,? extends R1> mapper)
Same as
map(Function) except that the Function must also
implement Serializable |
<U> CacheStream<U> |
DoubleCacheStream.mapToObj(DoubleFunction<? extends U> mapper) |
<U> CacheStream<U> |
IntCacheStream.mapToObj(IntFunction<? extends U> mapper) |
<U> CacheStream<U> |
LongCacheStream.mapToObj(LongFunction<? extends U> mapper) |
default <U> CacheStream<U> |
DoubleCacheStream.mapToObj(SerializableDoubleFunction<? extends U> mapper)
Same as
DoubleCacheStream.mapToObj(DoubleFunction) except that the DoubleFunction must also
implement Serializable |
default <U> CacheStream<U> |
IntCacheStream.mapToObj(SerializableIntFunction<? extends U> mapper)
Same as
IntCacheStream.mapToObj(IntFunction) except that the IntFunction must also
implement Serializable |
default <U> CacheStream<U> |
LongCacheStream.mapToObj(SerializableLongFunction<? extends U> mapper)
Same as
LongCacheStream.mapToObj(LongFunction) except that the LongFunction must also
implement Serializable. |
CacheStream<R> |
CacheStream.onClose(Runnable closeHandler) |
CacheStream<R> |
CacheStream.parallel() |
CacheStream<R> |
CacheStream.parallelDistribution() |
CacheStream<E> |
CacheCollection.parallelStream() |
CacheStream<R> |
CacheStream.peek(Consumer<? super R> action) |
default CacheStream<R> |
CacheStream.peek(SerializableConsumer<? super R> action)
Same as
peek(Consumer) except that the Consumer must also implement Serializable |
CacheStream<R> |
CacheStream.segmentCompletionListener(BaseCacheStream.SegmentCompletionListener listener)
Allows registration of a segment completion listener that is notified when a segment has completed
processing.
|
CacheStream<R> |
CacheStream.sequential() |
CacheStream<R> |
CacheStream.sequentialDistribution()
This would disable sending requests to all other remote nodes compared to one at a time.
|
CacheStream<R> |
CacheStream.skip(long n) |
CacheStream<R> |
CacheStream.sorted() |
CacheStream<R> |
CacheStream.sorted(Comparator<? super R> comparator) |
default CacheStream<R> |
CacheStream.sorted(SerializableComparator<? super R> comparator)
Same as
sorted(Comparator) except that the Comparator must
also implement Serializable |
CacheStream<E> |
CacheCollection.stream() |
CacheStream<R> |
CacheStream.timeout(long timeout,
TimeUnit unit)
Sets a given time to wait for a remote operation to respond by.
|
CacheStream<R> |
CacheStream.unordered() |
Modifier and Type | Method and Description |
---|---|
CacheStream<Map.Entry<K,V>> |
SimpleCacheImpl.EntrySet.parallelStream() |
CacheStream<CacheEntry<K,V>> |
SimpleCacheImpl.CacheEntrySet.parallelStream() |
CacheStream<V> |
SimpleCacheImpl.Values.parallelStream() |
CacheStream<K> |
SimpleCacheImpl.KeySet.parallelStream() |
CacheStream<Map.Entry<K,V>> |
SimpleCacheImpl.EntrySet.stream() |
CacheStream<CacheEntry<K,V>> |
SimpleCacheImpl.CacheEntrySet.stream() |
CacheStream<V> |
SimpleCacheImpl.Values.stream() |
CacheStream<K> |
SimpleCacheImpl.KeySet.stream() |
Modifier and Type | Method and Description |
---|---|
static <K,V,C> CacheStream<CacheEntry<K,C>> |
CacheFilters.filterAndConvert(CacheStream<CacheEntry<K,V>> stream,
KeyValueFilterConverter<? super K,? super V,C> filterConverter) |
static <K,V,C> CacheStream<C> |
CacheFilters.filterAndConvertToValue(CacheStream<CacheEntry<K,V>> stream,
KeyValueFilterConverter<? super K,? super V,C> filterConverter) |
Modifier and Type | Method and Description |
---|---|
static <K,V,C> CacheStream<CacheEntry<K,C>> |
CacheFilters.filterAndConvert(CacheStream<CacheEntry<K,V>> stream,
KeyValueFilterConverter<? super K,? super V,C> filterConverter) |
static <K,V,C> CacheStream<C> |
CacheFilters.filterAndConvertToValue(CacheStream<CacheEntry<K,V>> stream,
KeyValueFilterConverter<? super K,? super V,C> filterConverter) |
Modifier and Type | Method and Description |
---|---|
CacheStream<CacheEntry<K,V>> |
DistributionBulkInterceptor.BackingEntrySet.parallelStream() |
CacheStream<CacheEntry<K,V>> |
DistributionBulkInterceptor.TxBackingEntrySet.parallelStream() |
CacheStream<K> |
DistributionBulkInterceptor.BackingKeySet.parallelStream() |
CacheStream<CacheEntry<K,V>> |
DistributionBulkInterceptor.BackingEntrySet.stream() |
CacheStream<CacheEntry<K,V>> |
DistributionBulkInterceptor.TxBackingEntrySet.stream() |
CacheStream<K> |
DistributionBulkInterceptor.BackingKeySet.stream() |
Modifier and Type | Class and Description |
---|---|
class |
DistributedCacheStream<Original,R>
Implementation of
CacheStream that provides support for lazily distributing stream methods to appropriate
nodes |
class |
IntermediateCacheStream<Original,R>
An intermediate cache stream used when an intermediate operation that requires both a remote and local portion
|
Modifier and Type | Field and Description |
---|---|
protected Supplier<CacheStream<Original>> |
AbstractCacheStream.supplier |
Modifier and Type | Method and Description |
---|---|
CacheStream<Double> |
DistributedDoubleCacheStream.boxed() |
CacheStream<Integer> |
DistributedIntCacheStream.boxed() |
CacheStream<Long> |
DistributedLongCacheStream.boxed() |
CacheStream<Double> |
IntermediateDoubleCacheStream.boxed() |
CacheStream<Integer> |
IntermediateIntCacheStream.boxed() |
CacheStream<Long> |
IntermediateLongCacheStream.boxed() |
CacheStream<R> |
DistributedCacheStream.disableRehashAware() |
CacheStream<R> |
IntermediateCacheStream.disableRehashAware() |
CacheStream<R> |
DistributedCacheStream.distinct() |
CacheStream<R> |
IntermediateCacheStream.distinct() |
CacheStream<R> |
DistributedCacheStream.distributedBatchSize(int batchSize) |
CacheStream<R> |
IntermediateCacheStream.distributedBatchSize(int batchSize) |
CacheStream<R> |
DistributedCacheStream.filter(Predicate<? super R> predicate) |
CacheStream<R> |
IntermediateCacheStream.filter(Predicate<? super R> predicate) |
CacheStream<R> |
DistributedCacheStream.filterKeys(Set<?> keys) |
CacheStream<R> |
IntermediateCacheStream.filterKeys(Set<?> keys) |
CacheStream<R> |
DistributedCacheStream.filterKeySegments(IntSet segments) |
CacheStream<R> |
IntermediateCacheStream.filterKeySegments(IntSet segments) |
CacheStream<R> |
DistributedCacheStream.filterKeySegments(Set<Integer> segments) |
CacheStream<R> |
IntermediateCacheStream.filterKeySegments(Set<Integer> segments) |
<R1> CacheStream<R1> |
DistributedCacheStream.flatMap(Function<? super R,? extends Stream<? extends R1>> mapper) |
<R1> CacheStream<R1> |
IntermediateCacheStream.flatMap(Function<? super R,? extends Stream<? extends R1>> mapper) |
CacheStream<R> |
DistributedCacheStream.limit(long maxSize) |
CacheStream<R> |
IntermediateCacheStream.limit(long maxSize) |
<R1> CacheStream<R1> |
DistributedCacheStream.map(Function<? super R,? extends R1> mapper) |
<R1> CacheStream<R1> |
IntermediateCacheStream.map(Function<? super R,? extends R1> mapper) |
<U> CacheStream<U> |
DistributedDoubleCacheStream.mapToObj(DoubleFunction<? extends U> mapper) |
<U> CacheStream<U> |
IntermediateDoubleCacheStream.mapToObj(DoubleFunction<? extends U> mapper) |
<U> CacheStream<U> |
DistributedIntCacheStream.mapToObj(IntFunction<? extends U> mapper) |
<U> CacheStream<U> |
IntermediateIntCacheStream.mapToObj(IntFunction<? extends U> mapper) |
<U> CacheStream<U> |
DistributedLongCacheStream.mapToObj(LongFunction<? extends U> mapper) |
<U> CacheStream<U> |
IntermediateLongCacheStream.mapToObj(LongFunction<? extends U> mapper) |
<U> CacheStream<U> |
DistributedDoubleCacheStream.mapToObj(SerializableDoubleFunction<? extends U> mapper) |
<U> CacheStream<U> |
DistributedIntCacheStream.mapToObj(SerializableIntFunction<? extends U> mapper) |
<U> CacheStream<U> |
DistributedLongCacheStream.mapToObj(SerializableLongFunction<? extends U> mapper) |
CacheStream<R> |
IntermediateCacheStream.onClose(Runnable closeHandler) |
CacheStream<R> |
IntermediateCacheStream.parallel() |
CacheStream<R> |
DistributedCacheStream.parallelDistribution() |
CacheStream<R> |
IntermediateCacheStream.parallelDistribution() |
CacheStream<R> |
DistributedCacheStream.peek(Consumer<? super R> action) |
CacheStream<R> |
IntermediateCacheStream.peek(Consumer<? super R> action) |
CacheStream<R> |
DistributedCacheStream.segmentCompletionListener(BaseCacheStream.SegmentCompletionListener listener) |
CacheStream<R> |
IntermediateCacheStream.segmentCompletionListener(BaseCacheStream.SegmentCompletionListener listener) |
CacheStream<R> |
IntermediateCacheStream.sequential() |
CacheStream<R> |
DistributedCacheStream.sequentialDistribution() |
CacheStream<R> |
IntermediateCacheStream.sequentialDistribution() |
CacheStream<R> |
DistributedCacheStream.skip(long n) |
CacheStream<R> |
IntermediateCacheStream.skip(long n) |
CacheStream<R> |
DistributedCacheStream.sorted() |
CacheStream<R> |
IntermediateCacheStream.sorted() |
CacheStream<R> |
DistributedCacheStream.sorted(Comparator<? super R> comparator) |
CacheStream<R> |
IntermediateCacheStream.sorted(Comparator<? super R> comparator) |
CacheStream<R> |
DistributedCacheStream.timeout(long timeout,
TimeUnit unit) |
CacheStream<R> |
IntermediateCacheStream.timeout(long timeout,
TimeUnit unit) |
CacheStream<R> |
IntermediateCacheStream.unordered() |
protected CacheStream<R> |
DistributedCacheStream.unwrap() |
Modifier and Type | Method and Description |
---|---|
protected static <R> Supplier<CacheStream<R>> |
DistributedCacheStream.supplierStreamCast(Supplier supplier) |
Constructor and Description |
---|
LockedStreamImpl(CacheStream<CacheEntry<K,V>> realStream,
long time,
TimeUnit unit) |
TxLockedStreamImpl(TransactionManager tm,
CacheStream<CacheEntry<K,V>> realStream,
long time,
TimeUnit unit) |
Constructor and Description |
---|
AbstractCacheStream(Address localAddress,
boolean parallel,
DistributionManager dm,
InvocationContext ctx,
Supplier<CacheStream<Original>> supplier,
boolean includeLoader,
int distributedBatchSize,
Executor executor,
ComponentRegistry registry,
Function<? super Original,?> toKeyFunction) |
DistributedCacheStream(Address localAddress,
boolean parallel,
DistributionManager dm,
InvocationContext ctx,
Supplier<CacheStream<R>> supplier,
boolean includeLoader,
int distributedBatchSize,
Executor executor,
ComponentRegistry registry,
Function<? super Original,?> toKeyFunction)
Standard constructor requiring all pertinent information to properly utilize a distributed cache stream
|
Modifier and Type | Method and Description |
---|---|
protected CacheStream<K> |
AbstractDelegatingKeyCacheSet.getStream(boolean parallel) |
protected CacheStream<CacheEntry<K,V>> |
AbstractDelegatingEntryCacheSet.getStream(boolean parallel) |
CacheStream<K> |
AbstractDelegatingKeyCacheSet.parallelStream() |
CacheStream<CacheEntry<K,V>> |
AbstractDelegatingEntryCacheSet.parallelStream() |
CacheStream<K> |
AbstractDelegatingKeyCacheSet.stream() |
CacheStream<CacheEntry<K,V>> |
AbstractDelegatingEntryCacheSet.stream() |
Modifier and Type | Class and Description |
---|---|
class |
LocalCacheStream<R>
CacheStream that is to be used locally.
|
Modifier and Type | Method and Description |
---|---|
CacheStream<Long> |
LocalLongCacheStream.boxed() |
CacheStream<V> |
ValueCacheCollection.parallelStream() |
CacheStream<V> |
ValueCacheCollection.stream() |
Constructor and Description |
---|
PersistenceEntryStreamSupplier(Cache<K,V> cache,
InternalEntryFactory iceFactory,
ToIntFunction<Object> toIntFunction,
CacheStream<CacheEntry<K,V>> inMemoryStream,
PersistenceManager persistenceManager) |
PersistenceKeyStreamSupplier(Cache<K,?> cache,
ToIntFunction<Object> toIntFunction,
CacheStream<K> inMemoryStream,
PersistenceManager persistenceManager) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractDelegatingCacheStream<R>
Delegate that forwards all the of the method calls to the underlying cache stream.
|
Modifier and Type | Field and Description |
---|---|
protected CacheStream<?> |
AbstractDelegatingCacheStream.underlyingStream |
Modifier and Type | Method and Description |
---|---|
CacheStream<R> |
AbstractDelegatingCacheStream.distinct() |
CacheStream<R> |
AbstractDelegatingCacheStream.filter(Predicate<? super R> predicate) |
<R1> CacheStream<R1> |
AbstractDelegatingCacheStream.flatMap(Function<? super R,? extends Stream<? extends R1>> mapper) |
CacheStream<R> |
AbstractDelegatingCacheStream.limit(long maxSize) |
<R1> CacheStream<R1> |
AbstractDelegatingCacheStream.map(Function<? super R,? extends R1> mapper) |
CacheStream<R> |
AbstractDelegatingCacheStream.onClose(Runnable closeHandler) |
CacheStream<R> |
AbstractDelegatingCacheStream.parallel() |
CacheStream<E> |
AbstractDelegatingCacheCollection.parallelStream() |
CacheStream<R> |
CacheSetMapper.parallelStream() |
CacheStream<R> |
WriteableCacheCollectionMapper.parallelStream() |
CacheStream<R> |
AbstractDelegatingCacheStream.peek(Consumer<? super R> action) |
CacheStream<R> |
AbstractDelegatingCacheStream.sequential() |
CacheStream<R> |
AbstractDelegatingCacheStream.skip(long n) |
CacheStream<R> |
AbstractDelegatingCacheStream.sorted() |
CacheStream<R> |
AbstractDelegatingCacheStream.sorted(Comparator<? super R> comparator) |
CacheStream<E> |
AbstractDelegatingCacheCollection.stream() |
CacheStream<R> |
CacheSetMapper.stream() |
CacheStream<R> |
WriteableCacheCollectionMapper.stream() |
CacheStream<R> |
AbstractDelegatingCacheStream.unordered() |
Constructor and Description |
---|
AbstractDelegatingCacheStream(CacheStream<R> stream) |
Copyright © 2021 JBoss by Red Hat. All rights reserved.