Uses of Interface
com.tangosol.util.function.Remote.BinaryOperator
-
Packages that use Remote.BinaryOperator Package Description com.oracle.coherence.concurrent.atomic A small toolkit of classes that support lock-free thread-safe programming on single variables.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. -
-
Uses of Remote.BinaryOperator in com.oracle.coherence.concurrent.atomic
Methods in com.oracle.coherence.concurrent.atomic with parameters of type Remote.BinaryOperator Modifier and Type Method Description CompletableFuture<V>
AsyncAtomicReference. 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.CompletableFuture<V>
AsyncLocalAtomicReference. accumulateAndGet(V x, Remote.BinaryOperator<V> accumulatorFunction)
CompletableFuture<V>
AsyncRemoteAtomicReference. accumulateAndGet(V x, Remote.BinaryOperator<V> accumulatorFunction)
V
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.V
LocalAtomicReference. accumulateAndGet(V x, Remote.BinaryOperator<V> accumulatorFunction)
V
RemoteAtomicReference. accumulateAndGet(V x, Remote.BinaryOperator<V> accumulatorFunction)
CompletableFuture<V>
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.CompletableFuture<V>
AsyncLocalAtomicReference. getAndAccumulate(V x, Remote.BinaryOperator<V> accumulatorFunction)
CompletableFuture<V>
AsyncRemoteAtomicReference. getAndAccumulate(V x, Remote.BinaryOperator<V> accumulatorFunction)
V
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.V
LocalAtomicReference. getAndAccumulate(V x, Remote.BinaryOperator<V> accumulatorFunction)
V
RemoteAtomicReference. getAndAccumulate(V x, Remote.BinaryOperator<V> accumulatorFunction)
-
Uses of Remote.BinaryOperator in com.tangosol.util.function
Methods in com.tangosol.util.function that return Remote.BinaryOperator Modifier and Type Method 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<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
.Methods in com.tangosol.util.function with parameters of type Remote.BinaryOperator Modifier and Type Method 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<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
Methods in com.tangosol.util.stream with parameters of type Remote.BinaryOperator Modifier and Type Method 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 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.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 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,?,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.
-