Package org.infinispan.stream.impl.tx
Class TxDistributedLongCacheStream<Original,K,V>
- java.lang.Object
-
- org.infinispan.stream.impl.AbstractCacheStream<Original,Long,LongStream,LongCacheStream>
-
- org.infinispan.stream.impl.DistributedLongCacheStream<Original>
-
- org.infinispan.stream.impl.tx.TxDistributedLongCacheStream<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<Long,LongStream>
,LongStream
,BaseCacheStream<Long,LongStream>
,LongCacheStream
public class TxDistributedLongCacheStream<Original,K,V> extends DistributedLongCacheStream<Original>
Long 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.LongStream
LongStream.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 DistributedDoubleCacheStream<Original>
doubleCacheStream()
protected DistributedIntCacheStream<Original>
intCacheStream()
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.DistributedLongCacheStream
allMatch, allMatch, anyMatch, anyMatch, asDoubleStream, 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, mapToDouble, mapToDouble, mapToInt, mapToInt, 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.LongCacheStream
onClose, parallel, sequential, unordered
-
Methods inherited from interface java.util.stream.LongStream
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,Long,LongStream,LongCacheStream>
primaryOnly
- determines whether we should utilize the primary segments or not.- Returns:
-
cacheStream
protected <R> DistributedCacheStream<Original,R> cacheStream()
- Overrides:
cacheStream
in classDistributedLongCacheStream<Original>
-
intCacheStream
protected DistributedIntCacheStream<Original> intCacheStream()
- Overrides:
intCacheStream
in classDistributedLongCacheStream<Original>
-
doubleCacheStream
protected DistributedDoubleCacheStream<Original> doubleCacheStream()
- Overrides:
doubleCacheStream
in classDistributedLongCacheStream<Original>
-
-