org.infinispan.stream.impl.tx

Class TxDistributedIntCacheStream

java.lang.Object

org.infinispan.stream.impl.AbstractCacheStream<Integer,IntStream,IntConsumer>

org.infinispan.stream.impl.DistributedIntCacheStream

org.infinispan.stream.impl.tx.TxDistributedIntCacheStream

All Implemented Interfaces:

AutoCloseable, BaseStream<Integer,IntStream>, IntStream

public class TxDistributedIntCacheStream
extends DistributedIntCacheStream

Int variant of tx cache stream

See Also:

TxDistributedCacheStream

Nested Class Summary

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, distinct, distributedBatchSize, dm, executor, includeLoader, intermediateOperations, intermediateType, iteratorOperation, keyEquivalence, keysToFilter, localIntermediateOperations, log, parallel, parallelDistribution, partition, registry, rehashAware, segmentCompletionListener, segmentsToFilter, sorted, supplier, timeout, timeoutUnit

Method Summary

Modifier and Type	Method and Description
protected <R> DistributedCacheStream<R>	cacheStream()
protected DistributedDoubleCacheStream	doubleCacheStream()
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.

Methods inherited from class org.infinispan.stream.impl.DistributedIntCacheStream

allMatch, anyMatch, asDoubleStream, asLongStream, average, boxed, collect, count, distinct, filter, findAny, findFirst, flatMap, forEach, forEachOrdered, iterator, limit, map, mapToDouble, mapToLong, mapToObj, max, min, noneMatch, peek, reduce, reduce, skip, sorted, spliterator, sum, summaryStatistics, toArray, unwrap

Methods inherited from class org.infinispan.stream.impl.AbstractCacheStream

addIntermediateOperation, addIntermediateOperationMap, addIntermediateOperationMap, close, isParallel, markDistinct, markSkip, markSorted, 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.IntStream

builder, concat, empty, generate, iterate, of, of, parallel, range, rangeClosed, sequential

Methods inherited from interface java.util.stream.BaseStream

close, isParallel, onClose, unordered

Method Detail

supplierForSegments

protected Supplier<Stream<CacheEntry>> supplierForSegments(ConsistentHash ch,
                                                           Set<Integer> targetSegments,
                                                           Set<Object> excludedKeys,
                                                           boolean primaryOnly)

Description copied from class: AbstractCacheStream

If 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.

Overrides:

supplierForSegments in class AbstractCacheStream<Integer,IntStream,IntConsumer>

primaryOnly - determines whether we should utilize the primary segments or not.

Returns:

cacheStream

protected <R> DistributedCacheStream<R> cacheStream()

Overrides:

cacheStream in class DistributedIntCacheStream

longCacheStream

protected DistributedLongCacheStream longCacheStream()

Overrides:

longCacheStream in class DistributedIntCacheStream

doubleCacheStream

protected DistributedDoubleCacheStream doubleCacheStream()

Overrides:

doubleCacheStream in class DistributedIntCacheStream