public interface DistributedLongStream extends LongStream
LongStream
that supports distributed stream
operations by replacing functional interfaces with their serializable
equivalents.LongStream.Builder
average, builder, concat, count, empty, findAny, findFirst, forEach, forEachOrdered, generate, iterate, iterator, max, min, of, of, range, rangeClosed, spliterator, sum, summaryStatistics, toArray
close, isParallel, onClose, unordered
default DistributedLongStream filter(DistributedLongPredicate predicate)
Serializable
variant of
java.util.stream.LongStream#filter(LongPredicate)
.default DistributedLongStream map(DistributedLongUnaryOperator mapper)
Serializable
variant of
java.util.stream.LongStream#map(LongUnaryOperator)
.default <U> DistributedStream<U> mapToObj(DistributedLongFunction<? extends U> mapper)
Serializable
variant of
java.util.stream.LongStream#mapToObj(LongFunction)
.default DistributedIntStream mapToInt(DistributedLongToIntFunction mapper)
Serializable
variant of
java.util.stream.LongStream#mapToInt(LongToIntFunction)
.default DistributedDoubleStream mapToDouble(DistributedLongToDoubleFunction mapper)
Serializable
variant of
java.util.stream.LongStream#mapToDouble(LongToDoubleFunction)
.default DistributedLongStream flatMap(DistributedLongFunction<? extends LongStream> mapper)
Serializable
variant of
java.util.stream.LongStream#flatMap(LongFunction)
.DistributedLongStream distinct()
distinct
in interface LongStream
DistributedLongStream sorted()
sorted
in interface LongStream
default DistributedLongStream peek(DistributedLongConsumer action)
Serializable
variant of
java.util.stream.LongStream#peek(LongConsumer)
.DistributedLongStream limit(long maxSize)
limit
in interface LongStream
DistributedLongStream skip(long n)
skip
in interface LongStream
default long reduce(long identity, DistributedLongBinaryOperator op)
Serializable
variant of
java.util.stream.LongStream#reduce(long, LongBinaryOperator)
.default OptionalLong reduce(DistributedLongBinaryOperator op)
Serializable
variant of
java.util.stream.LongStream#reduce(LongBinaryOperator)
.default <R> R collect(DistributedSupplier<R> supplier, DistributedObjLongConsumer<R> accumulator, DistributedBiConsumer<R,R> combiner)
Serializable
variant of
java.util.stream.LongStream#collect(Supplier, ObjLongConsumer, BiConsumer)
.default boolean anyMatch(DistributedLongPredicate predicate)
Serializable
variant of
java.util.stream.LongStream#anyMatch(LongPredicate)
.default boolean allMatch(DistributedLongPredicate predicate)
Serializable
variant of
java.util.stream.LongStream#allMatch(LongPredicate)
.default boolean noneMatch(DistributedLongPredicate predicate)
Serializable
variant of
java.util.stream.LongStream#noneMatch(LongPredicate)
.DistributedDoubleStream asDoubleStream()
asDoubleStream
in interface LongStream
DistributedStream<Long> boxed()
boxed
in interface LongStream
DistributedLongStream sequential()
sequential
in interface BaseStream<Long,LongStream>
sequential
in interface LongStream
DistributedLongStream parallel()
parallel
in interface BaseStream<Long,LongStream>
parallel
in interface LongStream
DistributedLongStream filter(LongPredicate predicate)
filter
in interface LongStream
DistributedLongStream map(LongUnaryOperator mapper)
map
in interface LongStream
<U> DistributedStream<U> mapToObj(LongFunction<? extends U> mapper)
mapToObj
in interface LongStream
DistributedIntStream mapToInt(LongToIntFunction mapper)
mapToInt
in interface LongStream
DistributedDoubleStream mapToDouble(LongToDoubleFunction mapper)
mapToDouble
in interface LongStream
DistributedLongStream flatMap(LongFunction<? extends LongStream> mapper)
flatMap
in interface LongStream
DistributedLongStream peek(LongConsumer action)
peek
in interface LongStream
long reduce(long identity, LongBinaryOperator op)
reduce
in interface LongStream
OptionalLong reduce(LongBinaryOperator op)
reduce
in interface LongStream
<R> R collect(Supplier<R> supplier, ObjLongConsumer<R> accumulator, BiConsumer<R,R> combiner)
collect
in interface LongStream
boolean anyMatch(LongPredicate predicate)
anyMatch
in interface LongStream
boolean allMatch(LongPredicate predicate)
allMatch
in interface LongStream
boolean noneMatch(LongPredicate predicate)
noneMatch
in interface LongStream
DistributedLongStream configure(JobConfig jobConfig)
jobConfig
- Job configuration which will be used while executing underlying DAGCopyright © 2018 Hazelcast, Inc.. All rights reserved.