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(org.infinispan.util.function.SerializablePredicate<? super R> predicate) |
|
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(Set<Integer> segments) |
Deprecated.
|
CacheStream<R> |
CacheStream.filterKeySegments(IntSet segments) |
Filters which entries are returned by what segment they are present in.
|
<R1> CacheStream<R1> |
CacheStream.flatMap(Function<? super R,? extends Stream<? extends R1>> mapper) |
default <R1> CacheStream<R1> |
CacheStream.flatMap(org.infinispan.util.function.SerializableFunction<? super R,? extends Stream<? extends R1>> mapper) |
|
CacheStream<R> |
CacheStream.limit(long maxSize) |
<R1> CacheStream<R1> |
CacheStream.map(Function<? super R,? extends R1> mapper) |
default <R1> CacheStream<R1> |
CacheStream.map(org.infinispan.util.function.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) |
default <U> CacheStream<U> |
DoubleCacheStream.mapToObj(org.infinispan.util.function.SerializableDoubleFunction<? extends U> mapper) |
|
<U> CacheStream<U> |
IntCacheStream.mapToObj(IntFunction<? extends U> mapper) |
default <U> CacheStream<U> |
IntCacheStream.mapToObj(org.infinispan.util.function.SerializableIntFunction<? extends U> mapper) |
|
<U> CacheStream<U> |
LongCacheStream.mapToObj(LongFunction<? extends U> mapper) |
default <U> CacheStream<U> |
LongCacheStream.mapToObj(org.infinispan.util.function.SerializableLongFunction<? extends U> mapper) |
|
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(org.infinispan.util.function.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(org.infinispan.util.function.SerializableComparator<? super R> comparator) |
|
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() |