org.infinispan.stream.impl.tx

Class TxDistributedDoubleCacheStream

java.lang.Object

org.infinispan.stream.impl.AbstractCacheStream<Double,DoubleStream,DoubleConsumer>

org.infinispan.stream.impl.DistributedDoubleCacheStream

org.infinispan.stream.impl.tx.TxDistributedDoubleCacheStream

All Implemented Interfaces:

AutoCloseable, BaseStream<Double,DoubleStream>, DoubleStream

public class TxDistributedDoubleCacheStream
extends DistributedDoubleCacheStream

Double variant of tx cache stream

See Also:

TxDistributedCacheStream

Nested Class Summary

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

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

builder, concat, empty, generate, iterate, of, of, parallel, 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<Double,DoubleStream,DoubleConsumer>

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

Returns:

cacheStream

protected <R> DistributedCacheStream<R> cacheStream()

Overrides:

cacheStream in class DistributedDoubleCacheStream

intCacheStream

protected DistributedIntCacheStream intCacheStream()

Overrides:

intCacheStream in class DistributedDoubleCacheStream

longCacheStream

protected DistributedLongCacheStream longCacheStream()

Overrides:

longCacheStream in class DistributedDoubleCacheStream