Package | Description |
---|---|
com.tangosol.util.stream |
Contains classes to support functional-style operations on remote streams of elements,
such as map-reduce transformations on collections.
|
Modifier and Type | Method | Description |
---|---|---|
RemoteLongStream |
RemoteIntStream.asLongStream()
Returns a
LongStream consisting of the elements of this stream,
converted to long . |
|
RemoteLongStream |
RemoteLongStream.filter(LongPredicate predicate)
Returns a stream consisting of the elements of this stream that match
the given predicate.
|
|
default RemoteLongStream |
RemoteLongStream.filter(Remote.LongPredicate predicate)
Returns a stream consisting of the elements of this stream that match
the given predicate.
|
|
RemoteLongStream |
RemoteLongStream.flatMap(LongFunction<? extends 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.
|
|
default RemoteLongStream |
RemoteLongStream.flatMap(Remote.LongFunction<? extends 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.
|
|
RemoteLongStream |
RemoteStream.flatMapToLong(Function<? super T,? extends 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. |
|
default RemoteLongStream |
RemoteStream.flatMapToLong(Remote.Function<? super T,? extends 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. |
|
RemoteLongStream |
RemoteLongStream.map(LongUnaryOperator mapper)
Returns a stream consisting of the results of applying the given
function to the elements of this stream.
|
|
default RemoteLongStream |
RemoteLongStream.map(Remote.LongUnaryOperator mapper)
Returns a stream consisting of the results of applying the given
function to the elements of this stream.
|
|
RemoteLongStream |
RemoteDoubleStream.mapToLong(DoubleToLongFunction mapper)
Returns a
LongStream consisting of the results of applying the
given function to the elements of this stream. |
|
RemoteLongStream |
RemoteIntStream.mapToLong(IntToLongFunction mapper)
Returns a
LongStream consisting of the results of applying the
given function to the elements of this stream. |
|
default RemoteLongStream |
RemoteDoubleStream.mapToLong(Remote.DoubleToLongFunction mapper)
Returns a
LongStream consisting of the results of applying the
given function to the elements of this stream. |
|
default RemoteLongStream |
RemoteIntStream.mapToLong(Remote.IntToLongFunction mapper)
Returns a
LongStream consisting of the results of applying the
given function to the elements of this stream. |
|
default RemoteLongStream |
RemoteStream.mapToLong(Remote.ToLongFunction<? super T> mapper)
Returns a
LongStream consisting of the results of applying the
given function to the elements of this stream. |
|
RemoteLongStream |
RemoteStream.mapToLong(ToLongFunction<? super T> mapper)
Returns a
LongStream consisting of the results of applying the
given function to the elements of this stream. |
|
default RemoteLongStream |
RemoteStream.mapToLong(ValueExtractor<? super T,? extends Number> mapper)
Returns an
LongStream consisting of the results of applying the
given extractor to the elements of this stream. |
|
RemoteLongStream |
RemoteLongStream.parallel() |
|
RemoteLongStream |
RemoteLongStream.peek(LongConsumer 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.
|
|
default RemoteLongStream |
RemoteLongStream.peek(Remote.LongConsumer 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.
|
|
RemoteLongStream |
RemoteLongStream.sequential() |
|
static <T extends Number> |
RemoteStream.toLongStream(RemoteStream<T> stream)
Convert stream of numbers into
RemoteLongStream . |