public interface DistributedLongStream extends LongStream
LongStream that supports distributed stream
operations by replacing functional interfaces with their serializable
equivalents.LongStream.Builderaverage, builder, concat, count, empty, findAny, findFirst, forEach, forEachOrdered, generate, iterate, iterator, max, min, of, of, range, rangeClosed, spliterator, sum, summaryStatistics, toArrayclose, isParallel, onClose, unordereddefault 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 LongStreamDistributedLongStream sorted()
sorted in interface LongStreamdefault DistributedLongStream peek(DistributedLongConsumer action)
Serializable variant of
java.util.stream.LongStream#peek(LongConsumer).DistributedLongStream limit(long maxSize)
limit in interface LongStreamDistributedLongStream skip(long n)
skip in interface LongStreamdefault 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 LongStreamDistributedStream<Long> boxed()
boxed in interface LongStreamDistributedLongStream sequential()
sequential in interface BaseStream<Long,LongStream>sequential in interface LongStreamDistributedLongStream parallel()
parallel in interface BaseStream<Long,LongStream>parallel in interface LongStreamDistributedLongStream filter(LongPredicate predicate)
filter in interface LongStreamDistributedLongStream map(LongUnaryOperator mapper)
map in interface LongStream<U> DistributedStream<U> mapToObj(LongFunction<? extends U> mapper)
mapToObj in interface LongStreamDistributedIntStream mapToInt(LongToIntFunction mapper)
mapToInt in interface LongStreamDistributedDoubleStream mapToDouble(LongToDoubleFunction mapper)
mapToDouble in interface LongStreamDistributedLongStream flatMap(LongFunction<? extends LongStream> mapper)
flatMap in interface LongStreamDistributedLongStream peek(LongConsumer action)
peek in interface LongStreamlong reduce(long identity,
LongBinaryOperator op)
reduce in interface LongStreamOptionalLong reduce(LongBinaryOperator op)
reduce in interface LongStream<R> R collect(Supplier<R> supplier, ObjLongConsumer<R> accumulator, BiConsumer<R,R> combiner)
collect in interface LongStreamboolean anyMatch(LongPredicate predicate)
anyMatch in interface LongStreamboolean allMatch(LongPredicate predicate)
allMatch in interface LongStreamboolean noneMatch(LongPredicate predicate)
noneMatch in interface LongStreamDistributedLongStream configure(JobConfig jobConfig)
jobConfig - Job configuration which will be used while executing underlying DAGCopyright © 2018 Hazelcast, Inc.. All rights reserved.