Package | Description |
---|---|
com.hazelcast.jet |
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
|
com.hazelcast.jet.stream |
java.util.stream implementation using Hazelcast Jet
|
Modifier and Type | Method and Description |
---|---|
<K,V> IStreamMap<K,V> |
JetInstance.getMap(String name)
Returns the distributed map instance with the specified name.
|
Modifier and Type | Method and Description |
---|---|
static <K,U> DistributedCollector.Reducer<Map.Entry<K,U>,IStreamMap<K,U>> |
DistributedCollectors.toIMap(String mapName)
Returns a
Reducer that accumulates elements into a
new distributed Hazelcast IMap whose keys and values are the keys and values of
the corresponding Map.Entry . |
static <T,K,U> DistributedCollector.Reducer<T,IStreamMap<K,U>> |
DistributedCollectors.toIMap(String mapName,
DistributedFunction<? super T,? extends K> keyMapper,
DistributedFunction<? super T,? extends U> valueMapper)
Returns a
Reducer that accumulates elements into a
new Hazelcast IMap whose keys and values are the result of applying the provided
mapping functions to the input elements. |
static <T,K,U> DistributedCollector.Reducer<T,IStreamMap<K,U>> |
DistributedCollectors.toIMap(String mapName,
DistributedFunction<? super T,? extends K> keyMapper,
DistributedFunction<? super T,? extends U> valueMapper,
DistributedBinaryOperator<U> mergeFunction)
Returns a
Reducer that accumulates elements into a
new distributed Hazelcast IMap whose keys and values are the result of applying
the provided mapping functions to the input elements. |
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.