T
- The type returned by the streamS
- The stream interfaceT_CONS
- The consumer for this streampublic abstract class AbstractCacheStream<T,S extends BaseStream<T,S>,T_CONS> extends Object implements BaseStream<T,S>
Modifier | Constructor and Description |
---|---|
protected |
AbstractCacheStream(AbstractCacheStream<T,S,T_CONS> other) |
protected |
AbstractCacheStream(Address localAddress,
boolean parallel,
DistributionManager dm,
Supplier<CacheStream<CacheEntry>> supplier,
ClusterStreamManager<Object> csm,
boolean includeLoader,
int distributedBatchSize,
Executor executor,
ComponentRegistry registry) |
Modifier and Type | Method and Description |
---|---|
protected S |
addIntermediateOperation(IntermediateOperation<T,S,T,S> intermediateOperation) |
protected void |
addIntermediateOperationMap(IntermediateOperation<T,S,?,?> intermediateOperation) |
protected <T2,S2 extends BaseStream<T2,S2>,S3 extends S2> |
addIntermediateOperationMap(IntermediateOperation<T,S,T2,S2> intermediateOperation,
S3 stream) |
void |
close() |
boolean |
isParallel() |
protected void |
markDistinct(IntermediateOperation<T,S,T,S> intermediateOperation,
org.infinispan.stream.impl.AbstractCacheStream.IntermediateType type) |
protected void |
markSkip(org.infinispan.stream.impl.AbstractCacheStream.IntermediateType type) |
protected void |
markSorted(org.infinispan.stream.impl.AbstractCacheStream.IntermediateType type) |
S |
onClose(Runnable closeHandler) |
S |
parallel() |
S |
sequential() |
protected Supplier<Stream<CacheEntry>> |
supplierForSegments(ConsistentHash ch,
Set<Integer> targetSegments,
Set<Object> excludedKeys) |
protected Supplier<Stream<CacheEntry>> |
supplierForSegments(ConsistentHash ch,
Set<Integer> targetSegments,
Set<Object> excludedKeys,
boolean usePrimary)
If
usePrimary is true the segments are the primary segments but only those that exist in
targetSegments. |
S |
unordered() |
protected abstract S |
unwrap() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
iterator, spliterator
protected final Log log
protected final Queue<IntermediateOperation> intermediateOperations
protected Queue<IntermediateOperation> localIntermediateOperations
protected final Address localAddress
protected final DistributionManager dm
protected final Supplier<CacheStream<CacheEntry>> supplier
protected final ClusterStreamManager csm
protected final boolean includeLoader
protected final Executor executor
protected final ComponentRegistry registry
protected final PartitionHandlingManager partition
protected final Equivalence keyEquivalence
protected Runnable closeRunnable
protected boolean parallel
protected boolean sorted
protected boolean distinct
protected org.infinispan.stream.impl.AbstractCacheStream.IntermediateType intermediateType
protected Boolean parallelDistribution
protected boolean rehashAware
protected Set<?> keysToFilter
protected int distributedBatchSize
protected CacheStream.SegmentCompletionListener segmentCompletionListener
protected org.infinispan.stream.impl.AbstractCacheStream.IteratorOperation iteratorOperation
protected long timeout
protected TimeUnit timeoutUnit
protected AbstractCacheStream(Address localAddress, boolean parallel, DistributionManager dm, Supplier<CacheStream<CacheEntry>> supplier, ClusterStreamManager<Object> csm, boolean includeLoader, int distributedBatchSize, Executor executor, ComponentRegistry registry)
protected AbstractCacheStream(AbstractCacheStream<T,S,T_CONS> other)
protected void markSorted(org.infinispan.stream.impl.AbstractCacheStream.IntermediateType type)
protected void markDistinct(IntermediateOperation<T,S,T,S> intermediateOperation, org.infinispan.stream.impl.AbstractCacheStream.IntermediateType type)
protected void markSkip(org.infinispan.stream.impl.AbstractCacheStream.IntermediateType type)
protected S addIntermediateOperation(IntermediateOperation<T,S,T,S> intermediateOperation)
protected void addIntermediateOperationMap(IntermediateOperation<T,S,?,?> intermediateOperation)
protected <T2,S2 extends BaseStream<T2,S2>,S3 extends S2> S3 addIntermediateOperationMap(IntermediateOperation<T,S,T2,S2> intermediateOperation, S3 stream)
protected abstract S unwrap()
public boolean isParallel()
isParallel
in interface BaseStream<T,S extends BaseStream<T,S>>
public S sequential()
sequential
in interface BaseStream<T,S extends BaseStream<T,S>>
public S parallel()
parallel
in interface BaseStream<T,S extends BaseStream<T,S>>
public S unordered()
unordered
in interface BaseStream<T,S extends BaseStream<T,S>>
public S onClose(Runnable closeHandler)
onClose
in interface BaseStream<T,S extends BaseStream<T,S>>
public void close()
close
in interface AutoCloseable
close
in interface BaseStream<T,S extends BaseStream<T,S>>
protected Supplier<Stream<CacheEntry>> supplierForSegments(ConsistentHash ch, Set<Integer> targetSegments, Set<Object> excludedKeys)
protected Supplier<Stream<CacheEntry>> supplierForSegments(ConsistentHash ch, Set<Integer> targetSegments, Set<Object> excludedKeys, boolean usePrimary)
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.ch
- targetSegments
- excludedKeys
- usePrimary
- determines whether we should utilize the primary segments or not.Copyright © 2020 JBoss, a division of Red Hat. All rights reserved.