Uses of Class
org.infinispan.stream.impl.local.LocalCacheStream
-
Packages that use LocalCacheStream Package Description org.infinispan.stream.impl org.infinispan.stream.impl.local -
-
Uses of LocalCacheStream in org.infinispan.stream.impl
Constructors in org.infinispan.stream.impl with parameters of type LocalCacheStream Constructor Description IntermediateCacheStream(BaseCacheStream remoteStream, IntermediateType type, LocalCacheStream<R> localStream, org.infinispan.stream.impl.IntermediateCacheStreamSupplier supplier)
-
Uses of LocalCacheStream in org.infinispan.stream.impl.local
Methods in org.infinispan.stream.impl.local that return LocalCacheStream Modifier and Type Method Description LocalCacheStream<Double>
LocalDoubleCacheStream. boxed()
LocalCacheStream<Integer>
LocalIntCacheStream. boxed()
LocalCacheStream<R>
LocalCacheStream. disableRehashAware()
LocalCacheStream<R>
LocalCacheStream. distinct()
LocalCacheStream<R>
LocalCacheStream. distributedBatchSize(int batchSize)
LocalCacheStream<R>
LocalCacheStream. filter(Predicate<? super R> predicate)
LocalCacheStream<R>
LocalCacheStream. filterKeys(Set<?> keys)
LocalCacheStream<R>
LocalCacheStream. filterKeySegments(Set<Integer> segments)
LocalCacheStream<R>
LocalCacheStream. filterKeySegments(org.infinispan.commons.util.IntSet segments)
<R1> LocalCacheStream<R1>
LocalCacheStream. flatMap(Function<? super R,? extends Stream<? extends R1>> mapper)
LocalCacheStream<R>
LocalCacheStream. limit(long maxSize)
<R1> LocalCacheStream<R1>
LocalCacheStream. map(Function<? super R,? extends R1> mapper)
<U> LocalCacheStream<U>
LocalDoubleCacheStream. mapToObj(DoubleFunction<? extends U> mapper)
<U> LocalCacheStream<U>
LocalIntCacheStream. mapToObj(IntFunction<? extends U> mapper)
<U> LocalCacheStream<U>
LocalLongCacheStream. mapToObj(LongFunction<? extends U> mapper)
LocalCacheStream<R>
LocalCacheStream. parallelDistribution()
LocalCacheStream<R>
LocalCacheStream. peek(Consumer<? super R> action)
LocalCacheStream<R>
LocalCacheStream. segmentCompletionListener(BaseCacheStream.SegmentCompletionListener listener)
LocalCacheStream<R>
LocalCacheStream. sequentialDistribution()
LocalCacheStream<R>
LocalCacheStream. skip(long n)
LocalCacheStream<R>
LocalCacheStream. sorted()
LocalCacheStream<R>
LocalCacheStream. sorted(Comparator<? super R> comparator)
LocalCacheStream<R>
LocalCacheStream. timeout(long timeout, TimeUnit unit)
-