Package | Description |
---|---|
com.hazelcast.jet |
Hazelcast Jet is a distributed computation engine running on top of
Hazelcast IMDG technology.
|
com.hazelcast.jet.pipeline |
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> IMapJet<K,V> |
JetInstance.getMap(String name)
Returns the distributed map instance with the specified name.
|
Modifier and Type | Method and Description |
---|---|
static <K,V> ContextFactory<IMapJet<K,V>> |
ContextFactories.iMapContext(String mapName)
Returns a factory that provides an
IMapJet as the context. |
Modifier and Type | Method and Description |
---|---|
static <T,K> DistributedCollector.Reducer<T,IMapJet<K,List<T>>> |
DistributedCollectors.groupingByToIMap(String mapName,
DistributedFunction<? super T,? extends K> classifier)
Variant of
java.util.stream.Collectors#groupingBy(Function) which, instead of
returning a map as the result, writes the grouped results to the
distributed IMapJet with the given name. |
static <T,K,A,D> DistributedCollector.Reducer<T,IMapJet<K,D>> |
DistributedCollectors.groupingByToIMap(String mapName,
DistributedFunction<? super T,? extends K> classifier,
DistributedCollector<? super T,A,D> downstream)
Variant of
java.util.stream.Collectors#groupingBy(Function, Collector) which,
instead of returning a map as the result, writes the grouped results to
the distributed IMapJet with the given name. |
static <K,U> DistributedCollector.Reducer<Map.Entry<K,U>,IMapJet<K,U>> |
DistributedCollectors.toIMap(String mapName)
Returns a collector similar to
java.util.stream.Collectors#toMap(Function,Function) which, instead of
returning a map as the result, writes the results to the distributed
IMapJet with the given name. |
static <T,K,U> DistributedCollector.Reducer<T,IMapJet<K,U>> |
DistributedCollectors.toIMap(String mapName,
DistributedFunction<? super T,? extends K> keyMapper,
DistributedFunction<? super T,? extends U> valueMapper)
Returns a collector similar to
java.util.stream.Collectors#toMap(Function,Function) which, instead of
creating a regular Java map, writes the results to the distributed
IMapJet with the given name. |
static <T,K,U> DistributedCollector.Reducer<T,IMapJet<K,U>> |
DistributedCollectors.toIMap(String mapName,
DistributedFunction<? super T,? extends K> keyMapper,
DistributedFunction<? super T,? extends U> valueMapper,
DistributedBinaryOperator<U> mergeFunction)
Variant of
java.util.stream.Collectors#toMap(Function, Function, BinaryOperator)
which, instead of returning a map as the result, writes the results
to the distributed IMapJet with the given name. |
Modifier and Type | Method and Description |
---|---|
static <K,V> DistributedStream<Map.Entry<K,V>> |
DistributedStream.fromMap(IMapJet<K,V> map)
Returns a
DistributedStream with this map as its source. |
static <K,V,T> DistributedStream<T> |
DistributedStream.fromMap(IMapJet<K,V> map,
Predicate<K,V> predicate,
DistributedFunction<Map.Entry<K,V>,T> projectionFn)
Returns a
DistributedStream with this map as its source. |
Copyright © 2018 Hazelcast, Inc.. All rights reserved.