public interface DistributedDoubleStream extends DoubleStream
DoubleStream
that supports
distributed stream operations by replacing functional interfaces with
their serializable equivalents.DoubleStream.Builder
average, builder, concat, count, empty, findAny, findFirst, generate, iterate, iterator, max, min, of, of, spliterator, sum, summaryStatistics, toArray
close, isParallel, onClose, unordered
default DistributedDoubleStream filter(DistributedDoublePredicate predicate)
Serializable
variant of
java.util.stream.DoubleStream#filter(DoublePredicate)
.default DistributedDoubleStream map(DistributedDoubleUnaryOperator mapper)
Serializable
variant of
java.util.stream.DoubleStream#map(DoubleUnaryOperator)
.default <U> DistributedStream<U> mapToObj(DistributedDoubleFunction<? extends U> mapper)
Serializable
variant of
java.util.stream.DoubleStream#mapToObj(DoubleFunction)
.default DistributedLongStream mapToLong(DistributedDoubleToLongFunction mapper)
Serializable
variant of
java.util.stream.DoubleStream#mapToLong(DoubleToLongFunction)
.default DistributedIntStream mapToInt(DistributedDoubleToIntFunction mapper)
Serializable
variant of
java.util.stream.DoubleStream#mapToInt(DoubleToIntFunction)
.default DistributedDoubleStream flatMap(DistributedDoubleFunction<? extends DoubleStream> mapper)
Serializable
variant of
java.util.stream.DoubleStream#flatMap(DoubleFunction)
.DistributedDoubleStream distinct()
distinct
in interface DoubleStream
DistributedDoubleStream sorted()
sorted
in interface DoubleStream
default DistributedDoubleStream peek(DistributedDoubleConsumer action)
Serializable
variant of
java.util.stream.DoubleStream#peek(DoubleConsumer)
.DistributedDoubleStream limit(long maxSize)
limit
in interface DoubleStream
DistributedDoubleStream skip(long n)
skip
in interface DoubleStream
default double reduce(double identity, DistributedDoubleBinaryOperator op)
Serializable
variant of
java.util.stream.DoubleStream#reduce(double, DoubleBinaryOperator)
.default OptionalDouble reduce(DistributedDoubleBinaryOperator op)
Serializable
variant of
java.util.stream.DoubleStream#reduce(DoubleBinaryOperator)
.default <R> R collect(DistributedSupplier<R> supplier, DistributedObjDoubleConsumer<R> accumulator, DistributedBiConsumer<R,R> combiner)
Serializable
variant of
java.util.stream.DoubleStream#collect(Supplier, ObjDoubleConsumer, BiConsumer)
.default boolean anyMatch(DistributedDoublePredicate predicate)
Serializable
variant of
java.util.stream.DoubleStream#anyMatch(DoublePredicate)
.default boolean allMatch(DistributedDoublePredicate predicate)
Serializable
variant of
java.util.stream.DoubleStream#allMatch(DoublePredicate)
.default boolean noneMatch(DistributedDoublePredicate predicate)
Serializable
variant of
java.util.stream.DoubleStream#noneMatch(DoublePredicate)
.DistributedStream<Double> boxed()
boxed
in interface DoubleStream
DistributedDoubleStream sequential()
sequential
in interface BaseStream<Double,DoubleStream>
sequential
in interface DoubleStream
DistributedDoubleStream parallel()
parallel
in interface BaseStream<Double,DoubleStream>
parallel
in interface DoubleStream
DistributedDoubleStream filter(DoublePredicate predicate)
filter
in interface DoubleStream
DistributedDoubleStream map(DoubleUnaryOperator mapper)
map
in interface DoubleStream
<U> DistributedStream<U> mapToObj(DoubleFunction<? extends U> mapper)
mapToObj
in interface DoubleStream
DistributedLongStream mapToLong(DoubleToLongFunction mapper)
mapToLong
in interface DoubleStream
DistributedIntStream mapToInt(DoubleToIntFunction mapper)
mapToInt
in interface DoubleStream
DistributedDoubleStream flatMap(DoubleFunction<? extends DoubleStream> mapper)
flatMap
in interface DoubleStream
DistributedDoubleStream peek(DoubleConsumer action)
peek
in interface DoubleStream
void forEach(DoubleConsumer action)
forEach
in interface DoubleStream
void forEachOrdered(DoubleConsumer action)
forEachOrdered
in interface DoubleStream
double reduce(double identity, DoubleBinaryOperator op)
reduce
in interface DoubleStream
OptionalDouble reduce(DoubleBinaryOperator op)
reduce
in interface DoubleStream
<R> R collect(Supplier<R> supplier, ObjDoubleConsumer<R> accumulator, BiConsumer<R,R> combiner)
collect
in interface DoubleStream
boolean anyMatch(DoublePredicate predicate)
anyMatch
in interface DoubleStream
boolean allMatch(DoublePredicate predicate)
allMatch
in interface DoubleStream
boolean noneMatch(DoublePredicate predicate)
noneMatch
in interface DoubleStream
DistributedDoubleStream configure(JobConfig jobConfig)
jobConfig
- Job configuration which will be used while executing underlying DAGCopyright © 2018 Hazelcast, Inc.. All rights reserved.