AbstractDelegatingCacheStream<R> |
AbstractDelegatingCacheStream.disableRehashAware() |
AbstractDelegatingCacheStream<R> |
AbstractDelegatingCacheStream.distributedBatchSize(int batchSize) |
AbstractDelegatingCacheStream<R> |
AbstractDelegatingCacheStream.filterKeys(Set<?> keys) |
AbstractDelegatingCacheStream<R> |
AbstractDelegatingCacheStream.filterKeySegments(IntSet segments) |
AbstractDelegatingCacheStream<R> |
AbstractDelegatingCacheStream.filterKeySegments(Set<Integer> segments) |
AbstractDelegatingCacheStream<R> |
AbstractDelegatingCacheStream.parallelDistribution() |
AbstractDelegatingCacheStream<R> |
AbstractDelegatingCacheStream.segmentCompletionListener(BaseCacheStream.SegmentCompletionListener listener) |
AbstractDelegatingCacheStream<R> |
AbstractDelegatingCacheStream.sequentialDistribution() |
AbstractDelegatingCacheStream<R> |
AbstractDelegatingCacheStream.timeout(long timeout,
TimeUnit unit) |