public class TxDistributedDoubleCacheStream extends DistributedDoubleCacheStream
TxDistributedCacheStream
DoubleStream.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 DistributedIntCacheStream |
intCacheStream() |
protected DistributedLongCacheStream |
longCacheStream() |
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, average, boxed, collect, count, distinct, filter, findAny, findFirst, flatMap, forEach, forEachOrdered, iterator, limit, map, mapToInt, mapToLong, 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, 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<Double,DoubleStream,DoubleConsumer>
primaryOnly
- determines whether we should utilize the primary segments or not.protected <R> DistributedCacheStream<R> cacheStream()
cacheStream
in class DistributedDoubleCacheStream
protected DistributedIntCacheStream intCacheStream()
intCacheStream
in class DistributedDoubleCacheStream
protected DistributedLongCacheStream longCacheStream()
longCacheStream
in class DistributedDoubleCacheStream
Copyright © 2022 JBoss, a division of Red Hat. All rights reserved.