Uses of Interface
com.hazelcast.function.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 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.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 Description static <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
Methods in com.hazelcast.jet.aggregate with parameters of type BinaryOperatorEx Modifier and Type Method 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 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
Methods in com.hazelcast.jet.core.processor with parameters of type BinaryOperatorEx Modifier and Type Method 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 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
Methods in com.hazelcast.jet.pipeline with parameters of type BinaryOperatorEx Modifier and Type Method 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 HazelcastIMap
.static <K, V> Sink<Map.Entry<K,V>>
Sinks. mapWithMerging(IMap<? super K,V> map, BinaryOperatorEx<V> mergeFn)
Convenience forSinks.mapWithMerging(IMap, FunctionEx, FunctionEx, BinaryOperatorEx)
withMap.Entry
as input item.static <K, V> Sink<Map.Entry<K,V>>
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
.static <K, V> Sink<Map.Entry<K,V>>
Sinks. remoteMapWithMerging(String mapName, ClientConfig clientConfig, BinaryOperatorEx<V> mergeFn)
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
.