## Uses of Interface
com.hazelcast.jet.function.BinaryOperatorEx

- Packages that use BinaryOperatorEx
  Package | Description
  --- | ---
  com.hazelcast.jet.aggregate | Contains `AggregateOperation` and several its variants, as well as a builder object for the aggregate operations.
  com.hazelcast.jet.core.processor | Contains static utility classes with factories of Jet processors.
  com.hazelcast.jet.function | Serializable and exception-declaring variants of functional interfaces from `java.util.function`.
  com.hazelcast.jet.pipeline | The Pipeline API is Jet's high-level API to build and execute distributed computation jobs.

- - ### Uses of BinaryOperatorEx in com.hazelcast.jet.aggregate

    Methods in com.hazelcast.jet.aggregate with parameters of type BinaryOperatorEx
    Modifier and Type | Method and Description
    --- | ---
    `static <T,A> AggregateOperation1<T,MutableReference<A>,A>` | AggregateOperations.`reducing(A emptyAccValue, FunctionEx<? super T,? extends A> toAccValueFn, BinaryOperatorEx<A> combineAccValuesFn, BinaryOperatorEx<A> deductAccValueFn)` Returns an aggregate operation that constructs the result through the process of immutable reduction: The initial accumulated value is `emptyAccValue`.
    `static <T,A> AggregateOperation1<T,MutableReference<A>,A>` | AggregateOperations.`reducing(A emptyAccValue, FunctionEx<? super T,? extends A> toAccValueFn, BinaryOperatorEx<A> combineAccValuesFn, BinaryOperatorEx<A> deductAccValueFn)` Returns an aggregate operation that constructs the result through the process of immutable reduction: The initial accumulated value is `emptyAccValue`.
    `static <T,K,U> AggregateOperation1<T,Map<K,U>,Map<K,U>>` | AggregateOperations.`toMap(FunctionEx<? super T,? extends K> keyFn, FunctionEx<? super T,? extends U> valueFn, BinaryOperatorEx<U> mergeFn)` Returns an aggregate operation that accumulates the items into a `HashMap` whose keys and values are the result of applying the provided mapping functions.
    `static <T,K,U,M extends Map<K,U>> AggregateOperation1<T,M,M>` | AggregateOperations.`toMap(FunctionEx<? super T,? extends K> keyFn, FunctionEx<? super T,? extends U> valueFn, BinaryOperatorEx<U> mergeFn, SupplierEx<M> createMapFn)` Returns an aggregate operation that accumulates elements into a user-supplied `Map` instance.

  - ### Uses of BinaryOperatorEx in com.hazelcast.jet.core.processor

    Methods in com.hazelcast.jet.core.processor with parameters of type BinaryOperatorEx
    Modifier and Type | Method and Description
    --- | ---
    `static <T,K,V> ProcessorMetaSupplier` | SinkProcessors.`mergeMapP(String mapName, FunctionEx<? super T,? extends K> toKeyFn, FunctionEx<? super T,? extends V> toValueFn, BinaryOperatorEx<V> mergeFn)` Returns a supplier of processors for `Sinks.mapWithMerging(String, FunctionEx, FunctionEx, BinaryOperatorEx)`.
    `static <T,K,V> ProcessorMetaSupplier` | SinkProcessors.`mergeRemoteMapP(String mapName, ClientConfig clientConfig, FunctionEx<? super T,? extends K> toKeyFn, FunctionEx<? super T,? extends V> toValueFn, BinaryOperatorEx<V> mergeFn)` Returns a supplier of processors for `Sinks.remoteMapWithMerging(String, ClientConfig, FunctionEx, FunctionEx, BinaryOperatorEx)`.

  - ### Uses of BinaryOperatorEx in com.hazelcast.jet.function

    Methods in com.hazelcast.jet.function that return BinaryOperatorEx
    Modifier and Type | Method and Description
    --- | ---
    `static <T> BinaryOperatorEx<T>` | BinaryOperatorEx.`maxBy(Comparator<? super T> comparator)` `Serializable` variant of `java.util.function.BinaryOperator#maxBy(Comparator)`.
    `static <T> BinaryOperatorEx<T>` | BinaryOperatorEx.`minBy(Comparator<? super T> comparator)` `Serializable` variant of `java.util.function.BinaryOperator#minBy(Comparator)`.

  - ### Uses of BinaryOperatorEx in com.hazelcast.jet.pipeline

    Methods in com.hazelcast.jet.pipeline with parameters of type BinaryOperatorEx
    Modifier and Type | Method and Description
    --- | ---
    `static <T,K,V> Sink<T>` | Sinks.`mapWithMerging(IMap<? super K,? super V> map, FunctionEx<? super T,? extends K> toKeyFn, FunctionEx<? super T,? extends V> toValueFn, BinaryOperatorEx<V> mergeFn)` Returns a sink that uses the supplied functions to extract the key and value with which to update a Hazelcast `IMap`.
    `static <K,V> Sink<Map.Entry<K,V>>` | Sinks.`mapWithMerging(IMap<? super K,V> map, BinaryOperatorEx<V> mergeFn)` Convenience for `Sinks.mapWithMerging(IMap, FunctionEx, FunctionEx, BinaryOperatorEx)` with `Map.Entry` as input item.
    `static <K,V> Sink<Map.Entry<K,V>>` | Sinks.`mapWithMerging(String mapName, BinaryOperatorEx<V> mergeFn)` Convenience for `Sinks.mapWithMerging(String, FunctionEx, FunctionEx, BinaryOperatorEx)` with `Map.Entry` as input item.
    `static <T,K,V> Sink<T>` | Sinks.`mapWithMerging(String mapName, FunctionEx<? super T,? extends K> toKeyFn, FunctionEx<? super T,? extends V> toValueFn, BinaryOperatorEx<V> mergeFn)` Returns a sink that uses the supplied functions to extract the key and value with which to update a Hazelcast `IMap`.
    `static <K,V> Sink<Map.Entry<K,V>>` | Sinks.`remoteMapWithMerging(String mapName, ClientConfig clientConfig, BinaryOperatorEx<V> mergeFn)` Convenience for `Sinks.remoteMapWithMerging(java.lang.String, com.hazelcast.client.config.ClientConfig, com.hazelcast.jet.function.FunctionEx<? super T, ? extends K>, com.hazelcast.jet.function.FunctionEx<? super T, ? extends V>, com.hazelcast.jet.function.BinaryOperatorEx<V>)` with `Map.Entry` as input item.
    `static <T,K,V> Sink<T>` | Sinks.`remoteMapWithMerging(String mapName, ClientConfig clientConfig, FunctionEx<? super T,? extends K> toKeyFn, FunctionEx<? super T,? extends V> toValueFn, BinaryOperatorEx<V> mergeFn)` Returns a sink equivalent to `Sinks.mapWithMerging(String, BinaryOperatorEx)`, but for a map in a remote Hazelcast cluster identified by the supplied `ClientConfig`.

Copyright © 2019. All rights reserved.