Uses of Interface
com.hazelcast.jet.stream.DistributedIntStream

Packages that use DistributedIntStream

Package	Description
com.hazelcast.jet.stream	java.util.stream implementation using Hazelcast Jet

Uses of DistributedIntStream in com.hazelcast.jet.stream

Methods in com.hazelcast.jet.stream that return DistributedIntStream

Modifier and Type	Method and Description
DistributedIntStream	DistributedIntStream.configure(JobConfig jobConfig)
DistributedIntStream	DistributedIntStream.distinct()
default DistributedIntStream	DistributedIntStream.filter(DistributedIntPredicate predicate) Serializable variant of java.util.stream.IntStream#filter(IntPredicate).
DistributedIntStream	DistributedIntStream.filter(IntPredicate predicate)
default DistributedIntStream	DistributedIntStream.flatMap(DistributedIntFunction<? extends IntStream> mapper) Serializable variant of java.util.stream.IntStream#flatMap(IntFunction).
DistributedIntStream	DistributedIntStream.flatMap(IntFunction<? extends IntStream> mapper)
default DistributedIntStream	DistributedStream.flatMapToInt(DistributedFunction<? super T,? extends IntStream> mapper) Serializable variant of java.util.stream.Stream#flatMapToInt(Function).
DistributedIntStream	DistributedStream.flatMapToInt(Function<? super T,? extends IntStream> mapper)
DistributedIntStream	DistributedIntStream.limit(long maxSize)
default DistributedIntStream	DistributedIntStream.map(DistributedIntUnaryOperator mapper) Serializable variant of java.util.stream.IntStream#map(IntUnaryOperator).
DistributedIntStream	DistributedIntStream.map(IntUnaryOperator mapper)
default DistributedIntStream	DistributedDoubleStream.mapToInt(DistributedDoubleToIntFunction mapper) Serializable variant of java.util.stream.DoubleStream#mapToInt(DoubleToIntFunction).
default DistributedIntStream	DistributedLongStream.mapToInt(DistributedLongToIntFunction mapper) Serializable variant of java.util.stream.LongStream#mapToInt(LongToIntFunction).
default DistributedIntStream	DistributedStream.mapToInt(DistributedToIntFunction<? super T> mapper) Serializable variant of java.util.stream.Stream#mapToInt(ToIntFunction).
DistributedIntStream	DistributedDoubleStream.mapToInt(DoubleToIntFunction mapper)
DistributedIntStream	DistributedLongStream.mapToInt(LongToIntFunction mapper)
DistributedIntStream	DistributedStream.mapToInt(ToIntFunction<? super T> mapper)
DistributedIntStream	DistributedIntStream.parallel()
default DistributedIntStream	DistributedIntStream.peek(DistributedIntConsumer action) Serializable variant of java.util.stream.IntStream#peek(IntConsumer).
DistributedIntStream	DistributedIntStream.peek(IntConsumer action)
DistributedIntStream	DistributedIntStream.sequential()
DistributedIntStream	DistributedIntStream.skip(long n)
DistributedIntStream	DistributedIntStream.sorted()