public interface DistributedDoubleStream extends DoubleStream
DoubleStream that supports
distributed stream operations by replacing functional interfaces with
their serializable equivalents.DoubleStream.Builderaverage, builder, concat, count, empty, findAny, findFirst, generate, iterate, iterator, max, min, of, of, spliterator, sum, summaryStatistics, toArrayclose, isParallel, onClose, unordereddefault 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 DoubleStreamDistributedDoubleStream sorted()
sorted in interface DoubleStreamdefault DistributedDoubleStream peek(DistributedDoubleConsumer action)
Serializable variant of
java.util.stream.DoubleStream#peek(DoubleConsumer).DistributedDoubleStream limit(long maxSize)
limit in interface DoubleStreamDistributedDoubleStream skip(long n)
skip in interface DoubleStreamdefault 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 DoubleStreamDistributedDoubleStream sequential()
sequential in interface BaseStream<Double,DoubleStream>sequential in interface DoubleStreamDistributedDoubleStream parallel()
parallel in interface BaseStream<Double,DoubleStream>parallel in interface DoubleStreamDistributedDoubleStream filter(DoublePredicate predicate)
filter in interface DoubleStreamDistributedDoubleStream map(DoubleUnaryOperator mapper)
map in interface DoubleStream<U> DistributedStream<U> mapToObj(DoubleFunction<? extends U> mapper)
mapToObj in interface DoubleStreamDistributedLongStream mapToLong(DoubleToLongFunction mapper)
mapToLong in interface DoubleStreamDistributedIntStream mapToInt(DoubleToIntFunction mapper)
mapToInt in interface DoubleStreamDistributedDoubleStream flatMap(DoubleFunction<? extends DoubleStream> mapper)
flatMap in interface DoubleStreamDistributedDoubleStream peek(DoubleConsumer action)
peek in interface DoubleStreamvoid forEach(DoubleConsumer action)
forEach in interface DoubleStreamvoid forEachOrdered(DoubleConsumer action)
forEachOrdered in interface DoubleStreamdouble reduce(double identity,
DoubleBinaryOperator op)
reduce in interface DoubleStreamOptionalDouble reduce(DoubleBinaryOperator op)
reduce in interface DoubleStream<R> R collect(Supplier<R> supplier, ObjDoubleConsumer<R> accumulator, BiConsumer<R,R> combiner)
collect in interface DoubleStreamboolean anyMatch(DoublePredicate predicate)
anyMatch in interface DoubleStreamboolean allMatch(DoublePredicate predicate)
allMatch in interface DoubleStreamboolean noneMatch(DoublePredicate predicate)
noneMatch in interface DoubleStreamDistributedDoubleStream configure(JobConfig jobConfig)
jobConfig - Job configuration which will be used while executing underlying DAGCopyright © 2018 Hazelcast, Inc.. All rights reserved.