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.
|
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>> |
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. |
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) . |
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) . |
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> |
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 Hazelcast, Inc.. All rights reserved.