org.infinispan.stream.impl.tx

Class TxDistributedLongCacheStream

java.lang.Object

org.infinispan.stream.impl.AbstractCacheStream<Long,LongStream,LongConsumer>

org.infinispan.stream.impl.DistributedLongCacheStream

org.infinispan.stream.impl.tx.TxDistributedLongCacheStream

All Implemented Interfaces:

AutoCloseable, BaseStream<Long,LongStream>, LongStream

public class TxDistributedLongCacheStream
extends DistributedLongCacheStream

Long variant of tx cache stream

See Also:

TxDistributedCacheStream

Nested Class Summary

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, 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 DistributedIntCacheStream	intCacheStream()
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.DistributedLongCacheStream

allMatch, anyMatch, asDoubleStream, average, boxed, collect, count, distinct, filter, findAny, findFirst, flatMap, forEach, forEachOrdered, iterator, limit, map, mapToDouble, mapToInt, 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.LongStream

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<Long,LongStream,LongConsumer>

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

Returns:

cacheStream

protected <R> DistributedCacheStream<R> cacheStream()

Overrides:

cacheStream in class DistributedLongCacheStream

intCacheStream

protected DistributedIntCacheStream intCacheStream()

Overrides:

intCacheStream in class DistributedLongCacheStream

doubleCacheStream

protected DistributedDoubleCacheStream doubleCacheStream()

Overrides:

doubleCacheStream in class DistributedLongCacheStream