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(IntSet segments) |
LocalCacheStream<R> |
LocalCacheStream.filterKeySegments(Set<Integer> 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) |