public class TxDistributedIntCacheStream extends DistributedIntCacheStream
TxDistributedCacheStream
IntStream.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 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, asDoubleStream, asLongStream, average, boxed, collect, count, distinct, filter, findAny, findFirst, flatMap, forEach, forEachOrdered, iterator, limit, map, mapToDouble, 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, 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<Integer,IntStream,IntConsumer>
primaryOnly
- determines whether we should utilize the primary segments or not.protected <R> DistributedCacheStream<R> cacheStream()
cacheStream
in class DistributedIntCacheStream
protected DistributedLongCacheStream longCacheStream()
longCacheStream
in class DistributedIntCacheStream
protected DistributedDoubleCacheStream doubleCacheStream()
doubleCacheStream
in class DistributedIntCacheStream
Copyright © 2020 JBoss, a division of Red Hat. All rights reserved.