LocalIntCacheStream |
LocalIntCacheStream.disableRehashAware() |
LocalIntCacheStream |
LocalIntCacheStream.distinct() |
LocalIntCacheStream |
LocalIntCacheStream.distributedBatchSize(int batchSize) |
LocalIntCacheStream |
LocalIntCacheStream.filter(IntPredicate predicate) |
LocalIntCacheStream |
LocalIntCacheStream.filterKeys(Set<?> keys) |
LocalIntCacheStream |
LocalIntCacheStream.filterKeySegments(IntSet segments) |
LocalIntCacheStream |
LocalIntCacheStream.filterKeySegments(Set<Integer> segments) |
LocalIntCacheStream |
LocalIntCacheStream.flatMap(IntFunction<? extends IntStream> mapper) |
LocalIntCacheStream |
LocalCacheStream.flatMapToInt(Function<? super R,? extends IntStream> mapper) |
LocalIntCacheStream |
LocalIntCacheStream.limit(long maxSize) |
LocalIntCacheStream |
LocalIntCacheStream.map(IntUnaryOperator mapper) |
LocalIntCacheStream |
LocalDoubleCacheStream.mapToInt(DoubleToIntFunction mapper) |
LocalIntCacheStream |
LocalLongCacheStream.mapToInt(LongToIntFunction mapper) |
LocalIntCacheStream |
LocalCacheStream.mapToInt(ToIntFunction<? super R> mapper) |
LocalIntCacheStream |
LocalIntCacheStream.parallelDistribution() |
LocalIntCacheStream |
LocalIntCacheStream.peek(IntConsumer action) |
LocalIntCacheStream |
LocalIntCacheStream.segmentCompletionListener(BaseCacheStream.SegmentCompletionListener listener) |
LocalIntCacheStream |
LocalIntCacheStream.sequentialDistribution() |
LocalIntCacheStream |
LocalIntCacheStream.skip(long n) |
LocalIntCacheStream |
LocalIntCacheStream.sorted() |
LocalIntCacheStream |
LocalIntCacheStream.timeout(long timeout,
TimeUnit unit) |