Uses of Interface
com.tangosol.util.function.Remote.BinaryOperator
Package
Description
A small toolkit of classes that support lock-free thread-safe programming on single variables.
Contains Functional interfaces allowing remote execution of lambda expressions and method references.
Contains classes to support functional-style operations on remote streams of elements,
such as map-reduce transformations on collections.
-
Uses of Remote.BinaryOperator in com.oracle.coherence.concurrent.atomic
Modifier and TypeMethodDescriptionAsyncAtomicReference.accumulateAndGet
(V x, Remote.BinaryOperator<V> accumulatorFunction) Atomically updates the current value with the results of applying the given function to the current and given values, returning the updated value.AsyncLocalAtomicReference.accumulateAndGet
(V x, Remote.BinaryOperator<V> accumulatorFunction) AsyncRemoteAtomicReference.accumulateAndGet
(V x, Remote.BinaryOperator<V> accumulatorFunction) AtomicReference.accumulateAndGet
(V x, Remote.BinaryOperator<V> accumulatorFunction) Atomically updates the current value with the results of applying the given function to the current and given values, returning the updated value.LocalAtomicReference.accumulateAndGet
(V x, Remote.BinaryOperator<V> accumulatorFunction) RemoteAtomicReference.accumulateAndGet
(V x, Remote.BinaryOperator<V> accumulatorFunction) AsyncAtomicReference.getAndAccumulate
(V x, Remote.BinaryOperator<V> accumulatorFunction) Atomically updates the current value with the results of applying the given function to the current and given values, returning the previous value.AsyncLocalAtomicReference.getAndAccumulate
(V x, Remote.BinaryOperator<V> accumulatorFunction) AsyncRemoteAtomicReference.getAndAccumulate
(V x, Remote.BinaryOperator<V> accumulatorFunction) AtomicReference.getAndAccumulate
(V x, Remote.BinaryOperator<V> accumulatorFunction) Atomically updates the current value with the results of applying the given function to the current and given values, returning the previous value.LocalAtomicReference.getAndAccumulate
(V x, Remote.BinaryOperator<V> accumulatorFunction) RemoteAtomicReference.getAndAccumulate
(V x, Remote.BinaryOperator<V> accumulatorFunction) -
Uses of Remote.BinaryOperator in com.tangosol.util.function
Modifier and TypeMethodDescriptionstatic <T> Remote.BinaryOperator
<T> Remote.binaryOperator
(Remote.BinaryOperator<T> operator) Capture serializable BinaryOperator.static <K,
V, M extends Map<K, V>>
Remote.BinaryOperator<M> 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 <K,
V, M extends Map<K, V>>
Remote.BinaryOperator<M> 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 <T> Remote.BinaryOperator
<T> Remote.BinaryOperator.maxBy
(Remote.Comparator<? super T> comparator) Returns aRemote.BinaryOperator
which returns the greater of two elements according to the specifiedComparator
.static <T,
E extends Comparable<? super E>>
Remote.BinaryOperator<T> Remote.BinaryOperator.maxBy
(ValueExtractor<? super T, ? extends E> comparable) Returns aRemote.BinaryOperator
which returns the greater of two elements according to the specifiedComparable
value.static <T> Remote.BinaryOperator
<T> Remote.BinaryOperator.maxBy
(Comparator<? super T> comparator) Returns aRemote.BinaryOperator
which returns the greater of two elements according to the specifiedComparator
.static <T> Remote.BinaryOperator
<T> Remote.BinaryOperator.minBy
(Remote.Comparator<? super T> comparator) Returns aRemote.BinaryOperator
which returns the lesser of two elements according to the specifiedComparator
.static <T,
E extends Comparable<? super E>>
Remote.BinaryOperator<T> Remote.BinaryOperator.minBy
(ValueExtractor<? super T, ? extends E> comparable) Returns aRemote.BinaryOperator
which returns the lesser of two elements according to the specifiedComparable
value.static <T> Remote.BinaryOperator
<T> Remote.BinaryOperator.minBy
(Comparator<? super T> comparator) Returns aRemote.BinaryOperator
which returns the lesser of two elements according to the specifiedComparator
.Modifier and TypeMethodDescriptionstatic <T> Remote.BinaryOperator
<T> Remote.binaryOperator
(Remote.BinaryOperator<T> operator) Capture serializable BinaryOperator.static <K,
V, M extends Map<K, V>>
Remote.BinaryOperator<M> 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. -
Uses of Remote.BinaryOperator in com.tangosol.util.stream
Modifier and TypeMethodDescriptionstatic <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 newCollector
described by the givensupplier
,accumulator
,combiner
, andfinisher
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 newCollector
described by the givensupplier
,accumulator
, andcombiner
functions.RemoteStream.reduce
(Remote.BinaryOperator<T> accumulator) Performs a reduction on the elements of this stream, using an associative accumulation function, and returns anOptional
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 aCollector
which performs a reduction of its input elements under a specifiedBinaryOperator
.static <T> RemoteCollector
<T, SimpleHolder<T>, T> RemoteCollectors.reducing
(T identity, Remote.BinaryOperator<T> op) Returns aCollector
which performs a reduction of its input elements under a specifiedBinaryOperator
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 aCollector
which performs a reduction of its input elements under a specified mapping function andBinaryOperator
.static <T,
U> RemoteCollector <T, ?, U> RemoteCollectors.reducing
(U identity, Remote.Function<? super T, ? extends U> mapper, Remote.BinaryOperator<U> op) Returns aCollector
which performs a reduction of its input elements under a specified mapping function andBinaryOperator
.static <T,
U1, U2, K, V>
RemoteCollector<T, ?, ConcurrentMap<K, V>> RemoteCollectors.toConcurrentMap
(ValueExtractor<? super U1, ? extends K> keyMapper, ValueExtractor<? super U2, ? extends V> valueMapper, Remote.BinaryOperator<V> mergeFunction) Returns a concurrentCollector
that accumulates elements into aConcurrentMap
whose keys and values are the result of applying the provided mapping functions to the input elements.static <T,
U1, U2, K, V>
RemoteCollector<T, ?, Map<K, V>> RemoteCollectors.toMap
(ValueExtractor<? super U1, ? extends K> keyMapper, ValueExtractor<? super U2, ? extends V> valueMapper, Remote.BinaryOperator<V> mergeFunction) Returns aCollector
that accumulates elements into aMap
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>>
RemoteCollector<T, ?, M> RemoteCollectors.toMap
(ValueExtractor<? super U1, ? extends K> keyExtractor, ValueExtractor<? super U2, ? extends V> valueExtractor, Remote.BinaryOperator<V> mergeFunction, Remote.Supplier<M> mapSupplier) Returns aCollector
that accumulates elements into aMap
whose keys and values are the result of applying the provided mapping functions to the input elements.static <T,
U1, U2, K, V>
RemoteCollector<T, ?, Map<K, V>> RemoteCollectors.toUnmodifiableMap
(ValueExtractor<? super U1, ? extends K> keyMapper, ValueExtractor<? super U2, ? extends V> valueMapper, Remote.BinaryOperator<V> mergeFunction) Returns aCollector
that accumulates elements into an unmodifiable Map whose keys and values are the result of applying the provided mapping functions to the input elements.