Package | Description |
---|---|
com.hazelcast.jet |
Hazelcast Jet is a distributed computation engine running on top of
Hazelcast IMDG technology.
|
com.hazelcast.jet.stream |
java.util.stream implementation using Hazelcast Jet
|
Modifier and Type | Method and Description |
---|---|
<K,V> ICacheJet<K,V> |
JetCacheManager.getCache(String name)
Returns the cache instance with the specified, optionally prefixed, cache
name:
|
Modifier and Type | Method and Description |
---|---|
static <T,K> DistributedCollector.Reducer<T,ICacheJet<K,List<T>>> |
DistributedCollectors.groupingByToICache(String cacheName,
DistributedFunction<? super T,? extends K> classifier)
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
ICacheJet with the given name. |
static <T,K,A,D> DistributedCollector.Reducer<T,ICacheJet<K,D>> |
DistributedCollectors.groupingByToICache(String cacheName,
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 ICacheJet with the given name. |
static <K,U> DistributedCollector.Reducer<Map.Entry<K,U>,ICacheJet<K,U>> |
DistributedCollectors.toICache(String cacheName)
Variant of
java.util.stream.Collectors#toMap(Function, Function) which, instead of
returning a map as the result, writes the results to the distributed
ICacheJet with the given name. |
static <T,K,U> DistributedCollector.Reducer<T,ICacheJet<K,U>> |
DistributedCollectors.toICache(String cacheName,
DistributedFunction<? super T,? extends K> keyMapper,
DistributedFunction<? super T,? extends U> valueMapper)
Variant of
java.util.stream.Collectors#toMap(Function, Function) which, instead of
returning a map as the result, writes the results to the distributed
ICacheJet with the given name. |
static <T,K,U> DistributedCollector.Reducer<T,ICacheJet<K,U>> |
DistributedCollectors.toICache(String cacheName,
DistributedFunction<? super T,? extends K> keyMapper,
DistributedFunction<? super T,? extends U> valueMapper,
DistributedBinaryOperator<U> mergeFunction)
Variant of
java.util.stream.Collectors#toMap(Function, Function) which, instead of
returning a map as the result, writes the results to the distributed
ICacheJet with the given name. |
Modifier and Type | Method and Description |
---|---|
static <K,V> DistributedStream<Map.Entry<K,V>> |
DistributedStream.Cache.fromCache(ICacheJet<K,V> cache)
Returns a
DistributedStream with the supplied cache as its source. |
Copyright © 2018 Hazelcast, Inc.. All rights reserved.