Uses of Interface
com.tangosol.util.stream.RemoteStream
Package
Description
Contains classes to enable Repository-like access to Coherence data.
Contains various generic utilities.
Contains classes to support functional-style operations on remote streams of elements,
such as map-reduce transformations on collections.
-
Uses of RemoteStream in com.oracle.coherence.repository
Modifier and TypeMethodDescriptionAbstractRepository.stream()
Return a stream of all entities in this repository.Return a stream of all entities in this repository that satisfy the specified criteria.AbstractRepository.stream
(Collection<? extends ID> colIds) Return a stream of entities with the specified identifiers. -
Uses of RemoteStream in com.tangosol.util
Modifier and TypeMethodDescriptiondefault RemoteStream
<InvocableMap.Entry<K, V>> InvocableMap.stream()
Return a stream of all entries in this map.default RemoteStream
<InvocableMap.Entry<K, V>> Return a filtered stream of entries in this map.default <T,
E> RemoteStream <E> InvocableMap.stream
(Filter filter, ValueExtractor<T, ? extends E> extractor) Return a stream of values extracted from all the entries that satisfy the specified filter.default <T,
E> RemoteStream <E> InvocableMap.stream
(ValueExtractor<T, ? extends E> extractor) Return a stream of values extracted from the entries of this map.default RemoteStream
<InvocableMap.Entry<K, V>> InvocableMap.stream
(Collection<? extends K> collKeys) Return a stream of entries with the specified keys.default <T,
E> RemoteStream <E> InvocableMap.stream
(Collection<? extends K> collKeys, ValueExtractor<T, ? extends E> extractor) Return a stream of values extracted from the entries with the specified keys. -
Uses of RemoteStream in com.tangosol.util.stream
Modifier and TypeMethodDescriptionRemoteDoubleStream.boxed()
Returns aStream
consisting of the elements of this stream, boxed toDouble
.RemoteIntStream.boxed()
Returns aStream
consisting of the elements of this stream, each boxed to anInteger
.RemoteLongStream.boxed()
Returns aStream
consisting of the elements of this stream, each boxed to aLong
.static <K,
V> RemoteStream <InvocableMap.Entry<K, V>> RemoteStream.entrySet
(InvocableMap<K, V> map) Create aRemoteStream
of specified map's entries.default RemoteStream
<T> RemoteStream.filter
(Remote.Predicate<? super T> predicate) Returns a stream consisting of the elements of this stream that match the given predicate.Returns a stream consisting of the elements of this stream that match the given predicate.default <R> RemoteStream
<R> RemoteStream.flatMap
(Remote.Function<? super T, ? extends Stream<? extends R>> 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.<R> RemoteStream
<R> 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.static <K,
V> RemoteStream <K> RemoteStream.keySet
(InvocableMap<K, V> map) Create aRemoteStream
of specified map's keys.default <R> RemoteStream
<R> RemoteStream.map
(Remote.Function<? super T, ? extends R> mapper) Returns a stream consisting of the results of applying the given function to the elements of this stream.default <R> RemoteStream
<R> RemoteStream.map
(ValueExtractor<? super T, ? extends R> mapper) Returns a stream consisting of the results of applying the given extractor to the elements of this stream.<R> RemoteStream
<R> Returns a stream consisting of the results of applying the given function to the elements of this stream.default <R> RemoteStream
<R> RemoteStream.mapMulti
(Remote.BiConsumer<? super T, ? super Consumer<R>> mapper) Returns a stream consisting of the results of replacing each element of this stream with multiple elements, specifically zero or more elements.<R> RemoteStream
<R> RemoteStream.mapMulti
(BiConsumer<? super T, ? super Consumer<R>> mapper) Returns a stream consisting of the results of replacing each element of this stream with multiple elements, specifically zero or more elements.default <U> RemoteStream
<U> RemoteDoubleStream.mapToObj
(Remote.DoubleFunction<? extends U> mapper) Returns an object-valuedStream
consisting of the results of applying the given function to the elements of this stream.<U> RemoteStream
<U> RemoteDoubleStream.mapToObj
(DoubleFunction<? extends U> mapper) Returns an object-valuedStream
consisting of the results of applying the given function to the elements of this stream.default <U> RemoteStream
<U> RemoteIntStream.mapToObj
(Remote.IntFunction<? extends U> mapper) Returns an object-valuedStream
consisting of the results of applying the given function to the elements of this stream.<U> RemoteStream
<U> RemoteIntStream.mapToObj
(IntFunction<? extends U> mapper) Returns an object-valuedStream
consisting of the results of applying the given function to the elements of this stream.default <U> RemoteStream
<U> RemoteLongStream.mapToObj
(Remote.LongFunction<? extends U> mapper) Returns an object-valuedStream
consisting of the results of applying the given function to the elements of this stream.<U> RemoteStream
<U> RemoteLongStream.mapToObj
(LongFunction<? extends U> mapper) Returns an object-valuedStream
consisting of the results of applying the given function to the elements of this stream.RemoteStream.parallel()
Returns an equivalent stream that is parallel.default RemoteStream
<T> RemoteStream.peek
(Remote.Consumer<? super T> 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.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.RemoteStream.sequential()
Returns an equivalent stream that is sequential.RemoteStream.sorted()
Returns a stream consisting of the elements of this stream, sorted according to natural order.default RemoteStream
<T> RemoteStream.sorted
(Remote.Comparator<? super T> comparator) Returns a stream consisting of the elements of this stream, sorted according to the providedComparator
.default RemoteStream
<T> RemoteStream.sorted
(Remote.Comparator<? super T> comparator, boolean fInverse) Returns a stream consisting of the elements of this stream, sorted according to the providedComparator
.default <U> RemoteStream
<T> RemoteStream.sorted
(ValueExtractor<? super U, ? extends Comparable> extractor) Returns a stream consisting of the elements of this stream, sorted according to attribute extracted by the providedValueExtractor
.default <U> RemoteStream
<T> RemoteStream.sorted
(ValueExtractor<? super U, ? extends Comparable> extractor, boolean fInverse) Returns a stream consisting of the elements of this stream, sorted according to attribute extracted by the providedValueExtractor
.RemoteStream.sorted
(Comparator<? super T> comparator) Returns a stream consisting of the elements of this stream, sorted according to the providedComparator
.RemoteStream.unordered()
Returns an equivalent stream that is unordered.static <K,
V> RemoteStream <V> RemoteStream.values
(InvocableMap<K, V> map) Create aRemoteStream
of specified map's values.Modifier and TypeMethodDescriptionstatic <T extends Number>
RemoteDoubleStreamRemoteStream.toDoubleStream
(RemoteStream<T> stream) Convert stream of numbers intoRemoteDoubleStream
.static <T extends Number>
RemoteIntStreamRemoteStream.toIntStream
(RemoteStream<T> stream) Convert stream of numbers intoRemoteIntStream
.static <T extends Number>
RemoteLongStreamRemoteStream.toLongStream
(RemoteStream<T> stream) Convert stream of numbers intoRemoteLongStream
.