public class TxDistributedLongCacheStream extends DistributedLongCacheStream
TxDistributedCacheStream
LongStream.Builder
closeRunnable, csm, distinct, distributedBatchSize, dm, executor, includeLoader, intermediateOperations, intermediateType, iteratorOperation, keyEquivalence, keysToFilter, localIntermediateOperations, log, parallel, parallelDistribution, partition, registry, rehashAware, segmentCompletionListener, segmentsToFilter, sorted, supplier, timeout, timeoutUnit
Modifier and Type | Method and Description |
---|---|
protected <R> DistributedCacheStream<R> |
cacheStream() |
protected DistributedDoubleCacheStream |
doubleCacheStream() |
protected DistributedIntCacheStream |
intCacheStream() |
protected Supplier<Stream<CacheEntry>> |
supplierForSegments(ConsistentHash ch,
Set<Integer> targetSegments,
Set<Object> excludedKeys,
boolean primaryOnly)
If
usePrimary is true the segments are the primary segments but only those that exist in
targetSegments. |
allMatch, anyMatch, asDoubleStream, average, boxed, collect, count, distinct, filter, findAny, findFirst, flatMap, forEach, forEachOrdered, iterator, limit, map, mapToDouble, mapToInt, mapToObj, max, min, noneMatch, peek, reduce, reduce, skip, sorted, spliterator, sum, summaryStatistics, toArray, unwrap
addIntermediateOperation, addIntermediateOperationMap, addIntermediateOperationMap, close, isParallel, markDistinct, markSkip, markSorted, onClose, parallel, sequential, supplierForSegments, unordered
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
builder, concat, empty, generate, iterate, of, of, parallel, range, rangeClosed, sequential
close, isParallel, onClose, unordered
protected Supplier<Stream<CacheEntry>> supplierForSegments(ConsistentHash ch, Set<Integer> targetSegments, Set<Object> excludedKeys, boolean primaryOnly)
AbstractCacheStream
usePrimary
is true the segments are the primary segments but only those that exist in
targetSegments. However if usePrimary
is false then targetSegments
must be
provided and non null and this will be used specifically.supplierForSegments
in class AbstractCacheStream<Long,LongStream,LongConsumer>
primaryOnly
- determines whether we should utilize the primary segments or not.protected <R> DistributedCacheStream<R> cacheStream()
cacheStream
in class DistributedLongCacheStream
protected DistributedIntCacheStream intCacheStream()
intCacheStream
in class DistributedLongCacheStream
protected DistributedDoubleCacheStream doubleCacheStream()
doubleCacheStream
in class DistributedLongCacheStream
Copyright © 2024 JBoss, a division of Red Hat. All rights reserved.