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() Returns a stream consisting of the distinct elements of this stream.
default DistributedIntStream	DistributedIntStream.filter(DistributedIntPredicate predicate) Returns a stream consisting of the elements of this stream that match the given predicate.
DistributedIntStream	DistributedIntStream.filter(java.util.function.IntPredicate predicate)
default DistributedIntStream	DistributedIntStream.flatMap(DistributedIntFunction<? extends java.util.stream.IntStream> mapper) Returns a stream consisting of the results of replacing each element of this stream with the contents of a mapped stream produced by applying the provided mapping function to each element.
DistributedIntStream	DistributedIntStream.flatMap(java.util.function.IntFunction<? extends java.util.stream.IntStream> mapper)
default DistributedIntStream	DistributedStream.flatMapToInt(DistributedFunction<? super T,? extends java.util.stream.IntStream> mapper) Returns an IntStream consisting of the results of replacing each element of this stream with the contents of a mapped stream produced by applying the provided mapping function to each element.
DistributedIntStream	DistributedStream.flatMapToInt(java.util.function.Function<? super T,? extends java.util.stream.IntStream> mapper)
DistributedIntStream	DistributedIntStream.limit(long maxSize) Returns a stream consisting of the elements of this stream, truncated to be no longer than maxSize in length.
default DistributedIntStream	DistributedIntStream.map(DistributedIntUnaryOperator mapper) Returns a stream consisting of the results of applying the given function to the elements of this stream.
DistributedIntStream	DistributedIntStream.map(java.util.function.IntUnaryOperator mapper)
default DistributedIntStream	DistributedDoubleStream.mapToInt(DistributedDoubleToIntFunction mapper) Returns an IntStream consisting of the results of applying the given function to the elements of this stream.
default DistributedIntStream	DistributedLongStream.mapToInt(DistributedLongToIntFunction mapper) Returns an IntStream consisting of the results of applying the given function to the elements of this stream.
default DistributedIntStream	DistributedStream.mapToInt(DistributedToIntFunction<? super T> mapper) Returns an DistributedIntStream consisting of the results of applying the given function to the elements of this stream.
DistributedIntStream	DistributedDoubleStream.mapToInt(java.util.function.DoubleToIntFunction mapper)
DistributedIntStream	DistributedLongStream.mapToInt(java.util.function.LongToIntFunction mapper)
DistributedIntStream	DistributedStream.mapToInt(java.util.function.ToIntFunction<? super T> mapper)
DistributedIntStream	DistributedIntStream.parallel() Returns an equivalent stream that is parallel.
default DistributedIntStream	DistributedIntStream.peek(DistributedIntConsumer action) Returns a stream consisting of the elements of this stream, additionally performing the provided action on each element as elements are consumed from the resulting stream.
DistributedIntStream	DistributedIntStream.peek(java.util.function.IntConsumer action)
DistributedIntStream	DistributedIntStream.sequential() Returns an equivalent stream that is sequential.
DistributedIntStream	DistributedIntStream.skip(long n) Returns a stream consisting of the remaining elements of this stream after discarding the first n elements of the stream.
DistributedIntStream	DistributedIntStream.sorted() Returns a stream consisting of the elements of this stream in sorted order.