Package | Description |
---|---|
com.hazelcast.jet.stream |
java.util.stream implementation using Hazelcast Jet
|
Modifier and Type | Method and Description |
---|---|
<K,V> IStreamCache<K,V> |
JetCacheManager.getCache(String name)
Returns the cache instance with the specified prefixed cache name.
|
Modifier and Type | Method and Description |
---|---|
static <K,U> DistributedCollector.Reducer<Map.Entry<K,U>,IStreamCache<K,U>> |
DistributedCollectors.toICache(String cacheName)
Returns a
Reducer that accumulates elements into a
new distributed Hazelcast ICache whose keys and values are the keys and values of
the corresponding Cache.Entry . |
static <T,K,U> DistributedCollector.Reducer<T,IStreamCache<K,U>> |
DistributedCollectors.toICache(String cacheName,
DistributedFunction<? super T,? extends K> keyMapper,
DistributedFunction<? super T,? extends U> valueMapper)
Returns a
Reducer that accumulates elements into a
new Hazelcast ICache whose keys and values are the result of applying the provided
mapping functions to the input elements. |
static <T,K,U> DistributedCollector.Reducer<T,IStreamCache<K,U>> |
DistributedCollectors.toICache(String cacheName,
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 ICache whose keys and values are the result of applying
the provided mapping functions to the input elements. |
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.