public interface DistributedIntStream extends IntStream
IntStream that supports distributed stream
operations by replacing functional interfaces with their serializable
equivalents.IntStream.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 DistributedIntStream filter(DistributedIntPredicate predicate)
Serializable variant of java.util.stream.IntStream#filter(IntPredicate).default DistributedIntStream map(DistributedIntUnaryOperator mapper)
Serializable variant of
java.util.stream.IntStream#map(IntUnaryOperator).default <U> DistributedStream<U> mapToObj(DistributedIntFunction<? extends U> mapper)
Serializable variant of
java.util.stream.IntStream#mapToObj(IntFunction).default DistributedLongStream mapToLong(DistributedIntToLongFunction mapper)
Serializable variant of
java.util.stream.IntStream#mapToLong(IntToLongFunction).default DistributedDoubleStream mapToDouble(DistributedIntToDoubleFunction mapper)
Serializable variant of
java.util.stream.IntStream#mapToDouble(IntToDoubleFunction).default DistributedIntStream flatMap(DistributedIntFunction<? extends IntStream> mapper)
Serializable variant of
java.util.stream.IntStream#flatMap(IntFunction).DistributedIntStream distinct()
DistributedIntStream sorted()
default DistributedIntStream peek(DistributedIntConsumer action)
Serializable variant of
java.util.stream.IntStream#peek(IntConsumer).DistributedIntStream limit(long maxSize)
DistributedIntStream skip(long n)
default int reduce(int identity,
DistributedIntBinaryOperator op)
Serializable variant of
java.util.stream.IntStream#reduce(int, IntBinaryOperator).default OptionalInt reduce(DistributedIntBinaryOperator op)
Serializable variant of
java.util.stream.IntStream#reduce(IntBinaryOperator).default <R> R collect(DistributedSupplier<R> supplier, DistributedObjIntConsumer<R> accumulator, DistributedBiConsumer<R,R> combiner)
Serializable variant of
java.util.stream.IntStream#collect(Supplier, ObjIntConsumer, BiConsumer).default boolean anyMatch(DistributedIntPredicate predicate)
Serializable variant of
java.util.stream.IntStream#anyMatch(IntPredicate).default boolean allMatch(DistributedIntPredicate predicate)
Serializable variant of
java.util.stream.IntStream#allMatch(IntPredicate).default boolean noneMatch(DistributedIntPredicate predicate)
Serializable variant of
java.util.stream.IntStream#noneMatch(IntPredicate).DistributedLongStream asLongStream()
asLongStream in interface IntStreamDistributedDoubleStream asDoubleStream()
asDoubleStream in interface IntStreamDistributedStream<Integer> boxed()
DistributedIntStream sequential()
sequential in interface BaseStream<Integer,IntStream>sequential in interface IntStreamDistributedIntStream parallel()
DistributedIntStream filter(IntPredicate predicate)
DistributedIntStream map(IntUnaryOperator mapper)
<U> DistributedStream<U> mapToObj(IntFunction<? extends U> mapper)
DistributedLongStream mapToLong(IntToLongFunction mapper)
DistributedDoubleStream mapToDouble(IntToDoubleFunction mapper)
mapToDouble in interface IntStreamDistributedIntStream flatMap(IntFunction<? extends IntStream> mapper)
DistributedIntStream peek(IntConsumer action)
int reduce(int identity,
IntBinaryOperator op)
OptionalInt reduce(IntBinaryOperator op)
<R> R collect(Supplier<R> supplier, ObjIntConsumer<R> accumulator, BiConsumer<R,R> combiner)
boolean anyMatch(IntPredicate predicate)
boolean allMatch(IntPredicate predicate)
boolean noneMatch(IntPredicate predicate)
DistributedIntStream configure(JobConfig jobConfig)
jobConfig - Job configuration which will be used while executing underlying DAGCopyright © 2018 Hazelcast, Inc.. All rights reserved.