Package | Description |
---|---|
com.hazelcast.jet.stream |
java.util.stream implementation using Hazelcast Jet
|
Modifier and Type | Method and Description |
---|---|
DistributedDoubleStream |
DistributedIntStream.asDoubleStream()
Returns a
DoubleStream consisting of the elements of this stream,
converted to double . |
DistributedDoubleStream |
DistributedLongStream.asDoubleStream()
Returns a
DoubleStream consisting of the elements of this stream,
converted to double . |
DistributedDoubleStream |
DistributedDoubleStream.configure(JobConfig jobConfig) |
DistributedDoubleStream |
DistributedDoubleStream.distinct()
Returns a stream consisting of the distinct elements of this stream.
|
default DistributedDoubleStream |
DistributedDoubleStream.filter(DistributedDoublePredicate predicate)
Returns a stream consisting of the elements of this stream that match
the given predicate.
|
DistributedDoubleStream |
DistributedDoubleStream.filter(java.util.function.DoublePredicate predicate) |
default DistributedDoubleStream |
DistributedDoubleStream.flatMap(DistributedDoubleFunction<? extends java.util.stream.DoubleStream> 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.
|
DistributedDoubleStream |
DistributedDoubleStream.flatMap(java.util.function.DoubleFunction<? extends java.util.stream.DoubleStream> mapper) |
default DistributedDoubleStream |
DistributedStream.flatMapToDouble(DistributedFunction<? super T,? extends java.util.stream.DoubleStream> mapper)
Returns an
DoubleStream 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. |
DistributedDoubleStream |
DistributedStream.flatMapToDouble(java.util.function.Function<? super T,? extends java.util.stream.DoubleStream> mapper) |
DistributedDoubleStream |
DistributedDoubleStream.limit(long maxSize)
Returns a stream consisting of the elements of this stream, truncated
to be no longer than
maxSize in length. |
default DistributedDoubleStream |
DistributedDoubleStream.map(DistributedDoubleUnaryOperator mapper)
Returns a stream consisting of the results of applying the given
function to the elements of this stream.
|
DistributedDoubleStream |
DistributedDoubleStream.map(java.util.function.DoubleUnaryOperator mapper) |
default DistributedDoubleStream |
DistributedIntStream.mapToDouble(DistributedIntToDoubleFunction mapper)
Returns a
DistributedDoubleStream consisting of the results of applying the
given function to the elements of this stream. |
default DistributedDoubleStream |
DistributedLongStream.mapToDouble(DistributedLongToDoubleFunction mapper)
Returns a
DoubleStream consisting of the results of applying the
given function to the elements of this stream. |
default DistributedDoubleStream |
DistributedStream.mapToDouble(DistributedToDoubleFunction<? super T> mapper)
Returns a
DistributedDoubleStream consisting of the results of applying the
given function to the elements of this stream. |
DistributedDoubleStream |
DistributedIntStream.mapToDouble(java.util.function.IntToDoubleFunction mapper) |
DistributedDoubleStream |
DistributedLongStream.mapToDouble(java.util.function.LongToDoubleFunction mapper) |
DistributedDoubleStream |
DistributedStream.mapToDouble(java.util.function.ToDoubleFunction<? super T> mapper) |
DistributedDoubleStream |
DistributedDoubleStream.parallel()
Returns an equivalent stream that is parallel.
|
default DistributedDoubleStream |
DistributedDoubleStream.peek(DistributedDoubleConsumer 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.
|
DistributedDoubleStream |
DistributedDoubleStream.peek(java.util.function.DoubleConsumer action) |
DistributedDoubleStream |
DistributedDoubleStream.sequential()
Returns an equivalent stream that is sequential.
|
DistributedDoubleStream |
DistributedDoubleStream.skip(long n)
Returns a stream consisting of the remaining elements of this stream
after discarding the first
n elements of the stream. |
DistributedDoubleStream |
DistributedDoubleStream.sorted()
Returns a stream consisting of the elements of this stream in sorted
order.
|
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.