public class DistributedDoubleCacheStream extends AbstractCacheStream<Double,DoubleStream,DoubleConsumer> implements DoubleStream
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.DoubleStream.Builder
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
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.
|
addIntermediateOperation, addIntermediateOperationMap, addIntermediateOperationMap, close, isParallel, markDistinct, markSkip, markSorted, onClose, parallel, sequential, supplierForSegments, supplierForSegments, unordered
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
builder, concat, empty, generate, iterate, of, of, parallel, sequential
close, isParallel, onClose, unordered
protected DistributedDoubleCacheStream(AbstractCacheStream other)
other
- other instance of AbstractCacheStream
to copy details fromprotected DoubleStream unwrap()
unwrap
in class AbstractCacheStream<Double,DoubleStream,DoubleConsumer>
public DoubleStream filter(DoublePredicate predicate)
filter
in interface DoubleStream
public DoubleStream map(DoubleUnaryOperator mapper)
map
in interface DoubleStream
public <U> Stream<U> mapToObj(DoubleFunction<? extends U> mapper)
mapToObj
in interface DoubleStream
public IntStream mapToInt(DoubleToIntFunction mapper)
mapToInt
in interface DoubleStream
public LongStream mapToLong(DoubleToLongFunction mapper)
mapToLong
in interface DoubleStream
public DoubleStream flatMap(DoubleFunction<? extends DoubleStream> mapper)
flatMap
in interface DoubleStream
public DoubleStream distinct()
distinct
in interface DoubleStream
public DoubleStream sorted()
sorted
in interface DoubleStream
public DoubleStream peek(DoubleConsumer action)
peek
in interface DoubleStream
public DoubleStream limit(long maxSize)
limit
in interface DoubleStream
public DoubleStream skip(long n)
skip
in interface DoubleStream
public Stream<Double> boxed()
boxed
in interface DoubleStream
public void forEach(DoubleConsumer action)
forEach
in interface DoubleStream
public void forEachOrdered(DoubleConsumer action)
forEachOrdered
in interface DoubleStream
public double[] toArray()
toArray
in interface DoubleStream
public double reduce(double identity, DoubleBinaryOperator op)
reduce
in interface DoubleStream
public OptionalDouble reduce(DoubleBinaryOperator op)
reduce
in interface DoubleStream
public <R> R collect(Supplier<R> supplier, ObjDoubleConsumer<R> accumulator, BiConsumer<R,R> combiner)
collect
in interface DoubleStream
public double sum()
sum
in interface DoubleStream
public OptionalDouble min()
min
in interface DoubleStream
public OptionalDouble max()
max
in interface DoubleStream
public OptionalDouble average()
average
in interface DoubleStream
public DoubleSummaryStatistics summaryStatistics()
summaryStatistics
in interface DoubleStream
public boolean anyMatch(DoublePredicate predicate)
anyMatch
in interface DoubleStream
public boolean allMatch(DoublePredicate predicate)
allMatch
in interface DoubleStream
public boolean noneMatch(DoublePredicate predicate)
noneMatch
in interface DoubleStream
public OptionalDouble findFirst()
findFirst
in interface DoubleStream
public OptionalDouble findAny()
findAny
in interface DoubleStream
public PrimitiveIterator.OfDouble iterator()
iterator
in interface BaseStream<Double,DoubleStream>
iterator
in interface DoubleStream
public Spliterator.OfDouble spliterator()
spliterator
in interface BaseStream<Double,DoubleStream>
spliterator
in interface DoubleStream
public long count()
count
in interface DoubleStream
protected <R> DistributedCacheStream<R> cacheStream()
protected DistributedIntCacheStream intCacheStream()
protected DistributedLongCacheStream longCacheStream()
Copyright © 2016 JBoss, a division of Red Hat. All rights reserved.