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. |