R
- the type of streampublic class TxDistributedCacheStream<R> extends DistributedCacheStream<R>
CacheStream.SegmentCompletionListener
Stream.Builder<T>
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
Constructor and Description |
---|
TxDistributedCacheStream(Address localAddress,
boolean parallel,
DistributionManager dm,
Supplier<CacheStream<CacheEntry<K,V>>> supplier,
TxClusterStreamManager<?> csm,
boolean includeLoader,
int distributedBatchSize,
Executor executor,
ComponentRegistry registry,
Function<? super CacheEntry<K,V>,R> function,
LocalTxInvocationContext ctx) |
TxDistributedCacheStream(Address localAddress,
boolean parallel,
DistributionManager dm,
Supplier<CacheStream<CacheEntry<K,V>>> supplier,
TxClusterStreamManager<?> csm,
boolean includeLoader,
int distributedBatchSize,
Executor executor,
ComponentRegistry registry,
LocalTxInvocationContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected DistributedDoubleCacheStream |
doubleCacheStream() |
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, collect, collect, composeWithExceptions, count, disableRehashAware, distinct, distributedBatchSize, filter, filterKeys, filterKeySegments, findAny, findFirst, flatMap, flatMapToDouble, flatMapToInt, flatMapToLong, forEach, forEachOrdered, iterator, limit, map, mapToDouble, mapToInt, mapToLong, max, min, noneMatch, parallelDistribution, peek, reduce, reduce, reduce, segmentCompletionListener, sequentialDistribution, skip, sorted, sorted, spliterator, supplierStreamCast, timeout, toArray, 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
close, isParallel, onClose, parallel, sequential, unordered
public TxDistributedCacheStream(Address localAddress, boolean parallel, DistributionManager dm, Supplier<CacheStream<CacheEntry<K,V>>> supplier, TxClusterStreamManager<?> csm, boolean includeLoader, int distributedBatchSize, Executor executor, ComponentRegistry registry, LocalTxInvocationContext ctx)
public TxDistributedCacheStream(Address localAddress, boolean parallel, DistributionManager dm, Supplier<CacheStream<CacheEntry<K,V>>> supplier, TxClusterStreamManager<?> csm, boolean includeLoader, int distributedBatchSize, Executor executor, ComponentRegistry registry, Function<? super CacheEntry<K,V>,R> function, LocalTxInvocationContext ctx)
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<R,Stream<R>,Consumer<? super R>>
primaryOnly
- determines whether we should utilize the primary segments or not.protected DistributedDoubleCacheStream doubleCacheStream()
doubleCacheStream
in class DistributedCacheStream<R>
protected DistributedLongCacheStream longCacheStream()
longCacheStream
in class DistributedCacheStream<R>
protected DistributedIntCacheStream intCacheStream()
intCacheStream
in class DistributedCacheStream<R>
Copyright © 2017 JBoss, a division of Red Hat. All rights reserved.