Package | Description |
---|---|
com.hazelcast.jet.stream |
java.util.stream implementation using Hazelcast Jet
|
Modifier and Type | Method and Description |
---|---|
DistributedLongStream |
DistributedIntStream.asLongStream()
Returns a
LongStream consisting of the elements of this stream,
converted to long . |
DistributedLongStream |
DistributedLongStream.configure(JobConfig jobConfig) |
DistributedLongStream |
DistributedLongStream.distinct()
Returns a stream consisting of the distinct elements of this stream.
|
default DistributedLongStream |
DistributedLongStream.filter(DistributedLongPredicate predicate)
Returns a stream consisting of the elements of this stream that match
the given predicate.
|
DistributedLongStream |
DistributedLongStream.filter(java.util.function.LongPredicate predicate) |
default DistributedLongStream |
DistributedLongStream.flatMap(DistributedLongFunction<? extends java.util.stream.LongStream> 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.
|
DistributedLongStream |
DistributedLongStream.flatMap(java.util.function.LongFunction<? extends java.util.stream.LongStream> mapper) |
default DistributedLongStream |
DistributedStream.flatMapToLong(DistributedFunction<? super T,? extends java.util.stream.LongStream> mapper)
Returns an
LongStream 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. |
DistributedLongStream |
DistributedStream.flatMapToLong(java.util.function.Function<? super T,? extends java.util.stream.LongStream> mapper) |
DistributedLongStream |
DistributedLongStream.limit(long maxSize)
Returns a stream consisting of the elements of this stream, truncated
to be no longer than
maxSize in length. |
default DistributedLongStream |
DistributedLongStream.map(DistributedLongUnaryOperator mapper)
Returns a stream consisting of the results of applying the given
function to the elements of this stream.
|
DistributedLongStream |
DistributedLongStream.map(java.util.function.LongUnaryOperator mapper) |
default DistributedLongStream |
DistributedDoubleStream.mapToLong(DistributedDoubleToLongFunction mapper)
Returns a
LongStream consisting of the results of applying the
given function to the elements of this stream. |
default DistributedLongStream |
DistributedIntStream.mapToLong(DistributedIntToLongFunction mapper)
Returns a
DistributedLongStream consisting of the results of applying the
given function to the elements of this stream. |
default DistributedLongStream |
DistributedStream.mapToLong(DistributedToLongFunction<? super T> mapper)
Returns a
DistributedLongStream consisting of the results of applying the
given function to the elements of this stream. |
DistributedLongStream |
DistributedDoubleStream.mapToLong(java.util.function.DoubleToLongFunction mapper) |
DistributedLongStream |
DistributedIntStream.mapToLong(java.util.function.IntToLongFunction mapper) |
DistributedLongStream |
DistributedStream.mapToLong(java.util.function.ToLongFunction<? super T> mapper) |
DistributedLongStream |
DistributedLongStream.parallel()
Returns an equivalent stream that is parallel.
|
default DistributedLongStream |
DistributedLongStream.peek(DistributedLongConsumer 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.
|
DistributedLongStream |
DistributedLongStream.peek(java.util.function.LongConsumer action) |
DistributedLongStream |
DistributedLongStream.sequential()
Returns an equivalent stream that is sequential.
|
DistributedLongStream |
DistributedLongStream.skip(long n)
Returns a stream consisting of the remaining elements of this stream
after discarding the first
n elements of the stream. |
DistributedLongStream |
DistributedLongStream.sorted()
Returns a stream consisting of the elements of this stream in sorted
order.
|
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.