Uses of Interface
com.hazelcast.function.BinaryOperatorEx
Package
Description
Serializable and exception-declaring variants of functional interfaces from
java.util.function
.Contains
AggregateOperation
and its several variants, as well
as a builder object for the aggregate operations.Contains static utility classes with factories of Jet processors.
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
-
Uses of BinaryOperatorEx in com.hazelcast.function
Modifier and TypeMethodDescriptionstatic <T> BinaryOperatorEx<T>
BinaryOperatorEx.maxBy
(Comparator<? super T> comparator) Serializable
variant ofjava.util.function.BinaryOperator#maxBy(Comparator)
.static <T> BinaryOperatorEx<T>
BinaryOperatorEx.minBy
(Comparator<? super T> comparator) Serializable
variant ofjava.util.function.BinaryOperator#minBy(Comparator)
. -
Uses of BinaryOperatorEx in com.hazelcast.jet.aggregate
Modifier and TypeMethodDescriptionstatic <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 isemptyAccValue
.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 aHashMap
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-suppliedMap
instance. -
Uses of BinaryOperatorEx in com.hazelcast.jet.core.processor
Modifier and TypeMethodDescriptionstatic <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 forSinks.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 forSinks.remoteMapWithMerging(String, ClientConfig, FunctionEx, FunctionEx, BinaryOperatorEx)
. -
Uses of BinaryOperatorEx in com.hazelcast.jet.pipeline
Modifier and TypeMethodDescriptionstatic <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 HazelcastIMap
.Sinks.mapWithMerging
(IMap<? super K, V> map, BinaryOperatorEx<V> mergeFn) Convenience forSinks.mapWithMerging(IMap, FunctionEx, FunctionEx, BinaryOperatorEx)
withMap.Entry
as input item.Sinks.mapWithMerging
(String mapName, BinaryOperatorEx<V> mergeFn) Convenience forSinks.mapWithMerging(String, FunctionEx, FunctionEx, BinaryOperatorEx)
withMap.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 HazelcastIMap
.MapSinkBuilder.mergeFn
(BinaryOperatorEx<V> mergeFn) Set the function to merge the existing value with new value.Sinks.remoteMapWithMerging
(String mapName, ClientConfig clientConfig, BinaryOperatorEx<V> mergeFn) Convenience forSinks.remoteMapWithMerging(java.lang.String, com.hazelcast.client.config.ClientConfig, com.hazelcast.function.BinaryOperatorEx<V>)
withMap.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 toSinks.mapWithMerging(String, BinaryOperatorEx)
, but for a map in a remote Hazelcast cluster identified by the suppliedClientConfig
.Sinks.remoteMapWithMerging
(String mapName, DataConnectionRef dataConnectionRef, BinaryOperatorEx<V> mergeFn) The same as theSinks.remoteMapWithMerging(String, ClientConfig, BinaryOperatorEx)
method.static <T,
K, V> Sink<T> Sinks.remoteMapWithMerging
(String mapName, DataConnectionRef dataConnectionRef, FunctionEx<? super T, ? extends K> toKeyFn, FunctionEx<? super T, ? extends V> toValueFn, BinaryOperatorEx<V> mergeFn) The same as theSinks.remoteMapWithMerging(String, ClientConfig, FunctionEx, FunctionEx, BinaryOperatorEx)
method.