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

- Packages that use DistributedBinaryOperator
  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 DistributedBinaryOperator in com.hazelcast.jet.aggregate

    Methods in com.hazelcast.jet.aggregate with parameters of type DistributedBinaryOperator
    Modifier and Type | Method and Description
    --- | ---
    `static <T,A> AggregateOperation1<T,MutableReference<A>,A>` | AggregateOperations.`reducing(A emptyAccValue, DistributedFunction<? super T,? extends A> toAccValueFn, DistributedBinaryOperator<A> combineAccValuesFn, DistributedBinaryOperator<A> deductAccValueFn)` A reducing operation maintains an accumulated value that starts out as `emptyAccValue` and is iteratively transformed by applying `combineAccValuesFn` to it and each stream item's accumulated value, as returned from `toAccValueFn`.
    `static <T,A> AggregateOperation1<T,MutableReference<A>,A>` | AggregateOperations.`reducing(A emptyAccValue, DistributedFunction<? super T,? extends A> toAccValueFn, DistributedBinaryOperator<A> combineAccValuesFn, DistributedBinaryOperator<A> deductAccValueFn)` A reducing operation maintains an accumulated value that starts out as `emptyAccValue` and is iteratively transformed by applying `combineAccValuesFn` to it and each stream item's accumulated value, as returned from `toAccValueFn`.
    `static <T,K,U> AggregateOperation1<T,Map<K,U>,Map<K,U>>` | AggregateOperations.`toMap(DistributedFunction<? super T,? extends K> keyFn, DistributedFunction<? super T,? extends U> valueFn, DistributedBinaryOperator<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(DistributedFunction<? super T,? extends K> keyFn, DistributedFunction<? super T,? extends U> valueFn, DistributedBinaryOperator<U> mergeFn, DistributedSupplier<M> createMapFn)` Returns an `AggregateOperation1` that accumulates elements into a `Map` whose keys and values are the result of applying the provided mapping functions to the input elements.

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

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

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

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

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

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

Copyright © 2018. All rights reserved.