Package org.infinispan.stream.impl.tx
Class TxDistributedDoubleCacheStream<Original,K,V>
- java.lang.Object
-
- org.infinispan.stream.impl.AbstractCacheStream<Original,Double,DoubleStream,DoubleCacheStream>
-
- org.infinispan.stream.impl.DistributedDoubleCacheStream<Original>
-
- org.infinispan.stream.impl.tx.TxDistributedDoubleCacheStream<Original,K,V>
-
- Type Parameters:
Original
- original stream typeK
- the type of context entry keyV
- the type of context entry value
- All Implemented Interfaces:
AutoCloseable
,BaseStream<Double,DoubleStream>
,DoubleStream
,BaseCacheStream<Double,DoubleStream>
,DoubleCacheStream
public class TxDistributedDoubleCacheStream<Original,K,V> extends DistributedDoubleCacheStream<Original>
Double variant of tx cache stream- See Also:
TxDistributedCacheStream
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.infinispan.stream.impl.AbstractCacheStream
AbstractCacheStream.MapOpsExternalizer
-
Nested classes/interfaces inherited from interface org.infinispan.BaseCacheStream
BaseCacheStream.SegmentCompletionListener
-
Nested classes/interfaces inherited from interface java.util.stream.DoubleStream
DoubleStream.Builder
-
-
Field Summary
-
Fields inherited from class org.infinispan.stream.impl.AbstractCacheStream
closeRunnable, csm, distributedBatchSize, dm, executor, includeLoader, intermediateOperations, iteratorOperation, keyPartitioner, keysToFilter, parallel, parallelDistribution, partition, registry, rehashAware, segmentCompletionListener, segmentsToFilter, stateTransferLock, supplier, timeout, timeoutUnit, toKeyFunction
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected <R> DistributedCacheStream<Original,R>
cacheStream()
protected DistributedIntCacheStream<Original>
intCacheStream()
protected DistributedLongCacheStream<Original>
longCacheStream()
protected Supplier<Stream<Original>>
supplierForSegments(ConsistentHash ch, org.infinispan.commons.util.IntSet targetSegments, Set<Object> excludedKeys, boolean primaryOnly)
IfusePrimary
is true the segments are the primary segments but only those that exist in targetSegments.-
Methods inherited from class org.infinispan.stream.impl.DistributedDoubleCacheStream
allMatch, allMatch, anyMatch, anyMatch, average, boxed, collect, collect, count, disableRehashAware, distinct, distributedBatchSize, filter, filter, filterKeys, filterKeySegments, filterKeySegments, findAny, findFirst, flatMap, flatMap, forEach, forEach, forEach, forEach, forEachOrdered, getLog, iterator, limit, map, map, mapToInt, mapToInt, mapToLong, mapToLong, mapToObj, mapToObj, max, min, noneMatch, noneMatch, parallelDistribution, peek, peek, reduce, reduce, reduce, reduce, segmentCompletionListener, sequentialDistribution, skip, sorted, spliterator, sum, summaryStatistics, timeout, toArray, unwrap
-
Methods inherited from class org.infinispan.stream.impl.AbstractCacheStream
addIntermediateOperation, addIntermediateOperation, addIntermediateOperationMap, close, composeWithExceptions, isParallel, isPrimaryOwner, nonNullKeyFunction, onClose, parallel, sequential, supplierForSegments, unordered
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface java.util.stream.BaseStream
close, isParallel
-
Methods inherited from interface org.infinispan.DoubleCacheStream
onClose, parallel, sequential, unordered
-
Methods inherited from interface java.util.stream.DoubleStream
dropWhile, takeWhile
-
-
-
-
Method Detail
-
supplierForSegments
protected Supplier<Stream<Original>> supplierForSegments(ConsistentHash ch, org.infinispan.commons.util.IntSet targetSegments, Set<Object> excludedKeys, boolean primaryOnly)
Description copied from class:AbstractCacheStream
IfusePrimary
is true the segments are the primary segments but only those that exist in targetSegments. However ifusePrimary
is false thentargetSegments
must be provided and non null and this will be used specifically.- Overrides:
supplierForSegments
in classAbstractCacheStream<Original,Double,DoubleStream,DoubleCacheStream>
primaryOnly
- determines whether we should utilize the primary segments or not.- Returns:
-
cacheStream
protected <R> DistributedCacheStream<Original,R> cacheStream()
- Overrides:
cacheStream
in classDistributedDoubleCacheStream<Original>
-
intCacheStream
protected DistributedIntCacheStream<Original> intCacheStream()
- Overrides:
intCacheStream
in classDistributedDoubleCacheStream<Original>
-
longCacheStream
protected DistributedLongCacheStream<Original> longCacheStream()
- Overrides:
longCacheStream
in classDistributedDoubleCacheStream<Original>
-
-