Package | Description |
---|---|
com.tangosol.util.function |
Contains Functional interfaces allowing remote execution of lambda expressions and method references.
|
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 and Description |
---|---|
static <T> Remote.BinaryOperator<T> |
Remote.binaryOperator(Remote.BinaryOperator<T> operator)
Capture serializable BinaryOperator.
|
static <K,V,M extends Map<K,V>> |
Remote.BinaryOperator.mapMerger(BinaryOperator<V> mergeFunction)
BinaryOperator<Map> that merges the contents of its right
argument into its left argument, using the provided merge function to
handle duplicate keys. |
static <K,V,M extends Map<K,V>> |
Remote.BinaryOperator.mapMerger(Remote.BinaryOperator<V> mergeFunction)
BinaryOperator<Map> that merges the contents of its right
argument into its left argument, using the provided merge function to
handle duplicate keys. |
static <T> Remote.BinaryOperator<T> |
Remote.BinaryOperator.maxBy(Comparator<? super T> comparator)
Returns a
BinaryOperator which returns the greater of two
elements according to the specified Comparator . |
static <T> Remote.BinaryOperator<T> |
Remote.BinaryOperator.maxBy(Remote.Comparator<? super T> comparator)
Returns a
BinaryOperator which returns the greater of two
elements according to the specified Comparator . |
static <T> Remote.BinaryOperator<T> |
Remote.BinaryOperator.minBy(Comparator<? super T> comparator)
Returns a
BinaryOperator which returns the lesser of two
elements according to the specified Comparator . |
static <T> Remote.BinaryOperator<T> |
Remote.BinaryOperator.minBy(Remote.Comparator<? super T> comparator)
Returns a
BinaryOperator which returns the lesser of two
elements according to the specified Comparator . |
Modifier and Type | Method and Description |
---|---|
static <T> Remote.BinaryOperator<T> |
Remote.binaryOperator(Remote.BinaryOperator<T> operator)
Capture serializable BinaryOperator.
|
static <K,V,M extends Map<K,V>> |
Remote.BinaryOperator.mapMerger(Remote.BinaryOperator<V> mergeFunction)
BinaryOperator<Map> that merges the contents of its right
argument into its left argument, using the provided merge function to
handle duplicate keys. |
Modifier and Type | Method and Description |
---|---|
static <T,A,R> RemoteCollector<T,A,R> |
RemoteCollector.of(Remote.Supplier<A> supplier,
Remote.BiConsumer<A,T> accumulator,
Remote.BinaryOperator<A> combiner,
Remote.Function<A,R> finisher,
Collector.Characteristics... characteristics)
Returns a new
Collector described by the given supplier ,
accumulator , combiner , and finisher functions. |
static <T,R> RemoteCollector<T,R,R> |
RemoteCollector.of(Remote.Supplier<R> supplier,
Remote.BiConsumer<R,T> accumulator,
Remote.BinaryOperator<R> combiner,
Collector.Characteristics... characteristics)
Returns a new
Collector described by the given supplier ,
accumulator , and combiner functions. |
default Optional<T> |
RemoteStream.reduce(Remote.BinaryOperator<T> accumulator)
Performs a reduction on the elements of this stream, using an associative
accumulation function, and returns an
Optional describing the
reduced value, if any. |
default T |
RemoteStream.reduce(T identity,
Remote.BinaryOperator<T> accumulator)
Performs a reduction on the elements of this stream, using the provided
identity value and an associative accumulation function, and returns the
reduced value.
|
default <U> U |
RemoteStream.reduce(U identity,
Remote.BiFunction<U,? super T,U> accumulator,
Remote.BinaryOperator<U> combiner)
Performs a reduction on the elements of this stream, using the provided
identity, accumulation and combining functions.
|
static <T> RemoteCollector<T,?,Optional<T>> |
RemoteCollectors.reducing(Remote.BinaryOperator<T> op)
Returns a
Collector which performs a reduction of its input
elements under a specified BinaryOperator . |
static <T> RemoteCollector<T,SimpleHolder<T>,T> |
RemoteCollectors.reducing(T identity,
Remote.BinaryOperator<T> op)
Returns a
Collector which performs a reduction of its input
elements under a specified BinaryOperator using the provided
identity. |
static <T,U> RemoteCollector<T,?,U> |
RemoteCollectors.reducing(U identity,
Remote.BiFunction<? super U,? super T,? extends U> mapper,
Remote.BinaryOperator<U> op)
Returns a
Collector which performs a reduction of its input
elements under a specified mapping function and BinaryOperator . |
static <T,U> RemoteCollector<T,?,U> |
RemoteCollectors.reducing(U identity,
Remote.Function<? super T,? extends U> mapper,
Remote.BinaryOperator<U> op)
Returns a
Collector which performs a reduction of its input
elements under a specified mapping function and BinaryOperator . |
static <T,U1,U2,K,V> |
RemoteCollectors.toMap(ValueExtractor<? super U1,? extends K> keyMapper,
ValueExtractor<? super U2,? extends V> valueMapper,
Remote.BinaryOperator<V> mergeFunction)
Returns a
Collector that accumulates elements into a Map
whose keys and values are the result of applying the provided mapping
functions to the input elements. |
static <T,U1,U2,K,V,M extends Map<K,V>> |
RemoteCollectors.toMap(ValueExtractor<? super U1,? extends K> keyExtractor,
ValueExtractor<? super U2,? extends V> valueExtractor,
Remote.BinaryOperator<V> mergeFunction,
Remote.Supplier<M> mapSupplier)
Returns a
Collector that accumulates elements into a Map
whose keys and values are the result of applying the provided mapping
functions to the input elements. |