Package org.infinispan.stream.impl.tx
Class TxDistributedIntCacheStream<Original,K,V>
- java.lang.Object
-
- org.infinispan.stream.impl.AbstractCacheStream<Original,Integer,IntStream,IntCacheStream>
-
- org.infinispan.stream.impl.DistributedIntCacheStream<Original>
-
- org.infinispan.stream.impl.tx.TxDistributedIntCacheStream<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<Integer,IntStream>
,IntStream
,BaseCacheStream<Integer,IntStream>
,IntCacheStream
public class TxDistributedIntCacheStream<Original,K,V> extends DistributedIntCacheStream<Original>
Int 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.IntStream
IntStream.Builder
-
-
Field Summary
-
Fields inherited from class org.infinispan.stream.impl.AbstractCacheStream
closeRunnable, csm, distributedBatchSize, dm, executor, includeLoader, intermediateOperations, iteratorOperation, keyPartitioner, keysToFilter, localAddress, 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 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.DistributedIntCacheStream
allMatch, allMatch, anyMatch, anyMatch, asDoubleStream, asLongStream, 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, 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.IntCacheStream
onClose, parallel, sequential, unordered
-
-
-
-
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,Integer,IntStream,IntCacheStream>
primaryOnly
- determines whether we should utilize the primary segments or not.- Returns:
-
cacheStream
protected <R> DistributedCacheStream<Original,R> cacheStream()
- Overrides:
cacheStream
in classDistributedIntCacheStream<Original>
-
longCacheStream
protected DistributedLongCacheStream<Original> longCacheStream()
- Overrides:
longCacheStream
in classDistributedIntCacheStream<Original>
-
doubleCacheStream
protected DistributedDoubleCacheStream<Original> doubleCacheStream()
- Overrides:
doubleCacheStream
in classDistributedIntCacheStream<Original>
-
-