Package | Description |
---|---|
com.hazelcast.jet.stream |
java.util.stream implementation using Hazelcast Jet
|
Modifier and Type | Method and Description |
---|---|
static <T,K> DistributedCollector.Reducer<T,com.hazelcast.cache.ICache<K,List<T>>> |
DistributedCollectors.groupingByToICache(String cacheName,
DistributedFunction<? super T,? extends K> classifier)
Returns a
Reducer implementing a "group by" operation on
input elements of type T , grouping elements according to a
classification function, and returning the results in a
new distributed Hazelcast ICache . |
static <T,K,A,D> DistributedCollector.Reducer<T,com.hazelcast.cache.ICache<K,D>> |
DistributedCollectors.groupingByToICache(String cacheName,
DistributedFunction<? super T,? extends K> classifier,
DistributedCollector<? super T,A,D> downstream)
Returns a
Reducer implementing a cascaded "group by" operation
on input elements of type T , grouping elements according to a
classification function, and then performing a reduction operation on
the values associated with a given key using the specified downstream
DistributedCollector . |
static <T,K> DistributedCollector.Reducer<T,com.hazelcast.core.IMap<K,List<T>>> |
DistributedCollectors.groupingByToIMap(String mapName,
DistributedFunction<? super T,? extends K> classifier)
Returns a
Reducer implementing a "group by" operation on
input elements of type T , grouping elements according to a
classification function, and returning the results in a
new distributed Hazelcast IMap . |
static <T,K,A,D> DistributedCollector.Reducer<T,com.hazelcast.core.IMap<K,D>> |
DistributedCollectors.groupingByToIMap(String mapName,
DistributedFunction<? super T,? extends K> classifier,
DistributedCollector<? super T,A,D> downstream)
Returns a
Reducer implementing a cascaded "group by" operation
on input elements of type T , grouping elements according to a
classification function, and then performing a reduction operation on
the values associated with a given key using the specified downstream
DistributedCollector . |
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. |
static <T> DistributedCollector.Reducer<T,IStreamList<T>> |
DistributedCollectors.toIList(String listName)
Returns a
Reducer that accumulates the input elements into a
new Hazelcast IList . |
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. |
Modifier and Type | Method and Description |
---|---|
<R> R |
DistributedStream.collect(DistributedCollector.Reducer<? super T,R> reducer)
Terminate the stream using a reduction performed by
DistributedCollector.Reducer
and return the resulting value. |
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.