Uses of Interface
com.hazelcast.function.BinaryOperatorEx

Packages that use BinaryOperatorEx

Package	Description
com.hazelcast.function	Serializable and exception-declaring variants of functional interfaces from java.util.function.
com.hazelcast.jet.aggregate	Contains AggregateOperation and its several 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.pipeline	The Pipeline API is Jet's high-level API to build and execute distributed computation jobs.

Uses of BinaryOperatorEx in com.hazelcast.function

Methods in com.hazelcast.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.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.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.function.FunctionEx<? super T, ? extends K>, com.hazelcast.function.FunctionEx<? super T, ? extends V>, com.hazelcast.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.