org.infinispan.stream.impl

Class DistributedDoubleCacheStream

java.lang.Object

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

org.infinispan.stream.impl.DistributedDoubleCacheStream

All Implemented Interfaces:

AutoCloseable, BaseStream<Double,DoubleStream>, DoubleStream

Direct Known Subclasses:

TxDistributedDoubleCacheStream

public class DistributedDoubleCacheStream
extends AbstractCacheStream<Double,DoubleStream,DoubleConsumer>
implements DoubleStream

Implementation of DoubleStream that utilizes a lazily evaluated distributed back end execution. Note this class is only able to be created using Stream.mapToDouble(ToDoubleFunction) or similar methods from the CacheStream interface.

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, localAddress, localIntermediateOperations, log, parallel, parallelDistribution, partition, registry, rehashAware, segmentCompletionListener, segmentsToFilter, sorted, supplier, timeout, timeoutUnit

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	DistributedDoubleCacheStream(AbstractCacheStream other) This constructor is to be used only when a user calls a map or flat map method changing to a DoubleStream from a CacheStream, Stream, IntStream, LongStream etc.

Method Summary

Modifier and Type	Method and Description
boolean	allMatch(DoublePredicate predicate)
boolean	anyMatch(DoublePredicate predicate)
OptionalDouble	average()
Stream<Double>	boxed()
protected <R> DistributedCacheStream<R>	cacheStream()
<R> R	collect(Supplier<R> supplier, ObjDoubleConsumer<R> accumulator, BiConsumer<R,R> combiner)
long	count()
DoubleStream	distinct()
DoubleStream	filter(DoublePredicate predicate)
OptionalDouble	findAny()
OptionalDouble	findFirst()
DoubleStream	flatMap(DoubleFunction<? extends DoubleStream> mapper)
void	forEach(DoubleConsumer action)
void	forEachOrdered(DoubleConsumer action)
protected DistributedIntCacheStream	intCacheStream()
PrimitiveIterator.OfDouble	iterator()
DoubleStream	limit(long maxSize)
protected DistributedLongCacheStream	longCacheStream()
DoubleStream	map(DoubleUnaryOperator mapper)
IntStream	mapToInt(DoubleToIntFunction mapper)
LongStream	mapToLong(DoubleToLongFunction mapper)
<U> Stream<U>	mapToObj(DoubleFunction<? extends U> mapper)
OptionalDouble	max()
OptionalDouble	min()
boolean	noneMatch(DoublePredicate predicate)
DoubleStream	peek(DoubleConsumer action)
OptionalDouble	reduce(DoubleBinaryOperator op)
double	reduce(double identity, DoubleBinaryOperator op)
DoubleStream	skip(long n)
DoubleStream	sorted()
Spliterator.OfDouble	spliterator()
double	sum()
DoubleSummaryStatistics	summaryStatistics()
double[]	toArray()
protected DoubleStream	unwrap()

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

addIntermediateOperation, addIntermediateOperationMap, addIntermediateOperationMap, close, isParallel, markDistinct, markSkip, markSorted, onClose, parallel, sequential, supplierForSegments, 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

Constructor Detail

DistributedDoubleCacheStream

protected DistributedDoubleCacheStream(AbstractCacheStream other)

This constructor is to be used only when a user calls a map or flat map method changing to a DoubleStream from a CacheStream, Stream, IntStream, LongStream etc.

Parameters:

other - other instance of AbstractCacheStream to copy details from

Method Detail

unwrap

protected DoubleStream unwrap()

Specified by:

unwrap in class AbstractCacheStream<Double,DoubleStream,DoubleConsumer>

filter

public DoubleStream filter(DoublePredicate predicate)

Specified by:

filter in interface DoubleStream

map

public DoubleStream map(DoubleUnaryOperator mapper)

Specified by:

map in interface DoubleStream

mapToObj

public <U> Stream<U> mapToObj(DoubleFunction<? extends U> mapper)

Specified by:

mapToObj in interface DoubleStream

mapToInt

public IntStream mapToInt(DoubleToIntFunction mapper)

Specified by:

mapToInt in interface DoubleStream

mapToLong

public LongStream mapToLong(DoubleToLongFunction mapper)

Specified by:

mapToLong in interface DoubleStream

flatMap

public DoubleStream flatMap(DoubleFunction<? extends DoubleStream> mapper)

Specified by:

flatMap in interface DoubleStream

distinct

public DoubleStream distinct()

Specified by:

distinct in interface DoubleStream

sorted

public DoubleStream sorted()

Specified by:

sorted in interface DoubleStream

peek

public DoubleStream peek(DoubleConsumer action)

Specified by:

peek in interface DoubleStream

limit

public DoubleStream limit(long maxSize)

Specified by:

limit in interface DoubleStream

skip

public DoubleStream skip(long n)

Specified by:

skip in interface DoubleStream

boxed

public Stream<Double> boxed()

Specified by:

boxed in interface DoubleStream

forEach

public void forEach(DoubleConsumer action)

Specified by:

forEach in interface DoubleStream

forEachOrdered

public void forEachOrdered(DoubleConsumer action)

Specified by:

forEachOrdered in interface DoubleStream

toArray

public double[] toArray()

Specified by:

toArray in interface DoubleStream

reduce

public double reduce(double identity,
                     DoubleBinaryOperator op)

Specified by:

reduce in interface DoubleStream

reduce

public OptionalDouble reduce(DoubleBinaryOperator op)

Specified by:

reduce in interface DoubleStream

collect

public <R> R collect(Supplier<R> supplier,
                     ObjDoubleConsumer<R> accumulator,
                     BiConsumer<R,R> combiner)

Specified by:

collect in interface DoubleStream

sum

public double sum()

Specified by:

sum in interface DoubleStream

min

public OptionalDouble min()

Specified by:

min in interface DoubleStream

max

public OptionalDouble max()

Specified by:

max in interface DoubleStream

average

public OptionalDouble average()

Specified by:

average in interface DoubleStream

summaryStatistics

public DoubleSummaryStatistics summaryStatistics()

Specified by:

summaryStatistics in interface DoubleStream

anyMatch

public boolean anyMatch(DoublePredicate predicate)

Specified by:

anyMatch in interface DoubleStream

allMatch

public boolean allMatch(DoublePredicate predicate)

Specified by:

allMatch in interface DoubleStream

noneMatch

public boolean noneMatch(DoublePredicate predicate)

Specified by:

noneMatch in interface DoubleStream

findFirst

public OptionalDouble findFirst()

Specified by:

findFirst in interface DoubleStream

findAny

public OptionalDouble findAny()

Specified by:

findAny in interface DoubleStream

iterator

public PrimitiveIterator.OfDouble iterator()

Specified by:

iterator in interface BaseStream<Double,DoubleStream>

Specified by:

iterator in interface DoubleStream

spliterator

public Spliterator.OfDouble spliterator()

Specified by:

spliterator in interface BaseStream<Double,DoubleStream>

Specified by:

spliterator in interface DoubleStream

count

public long count()

Specified by:

count in interface DoubleStream

cacheStream

protected <R> DistributedCacheStream<R> cacheStream()

intCacheStream

protected DistributedIntCacheStream intCacheStream()

longCacheStream

protected DistributedLongCacheStream longCacheStream()