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,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 <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>,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. |
static <T> DistributedCollector.Reducer<T,IListJet<T>> |
DistributedCollectors.toIList(String listName)
Variant of
java.util.stream.Collectors#toList()
which, instead of returning a list as the result, writes the results to the
distributed IListJet 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 |
---|---|
<R> R |
DistributedStream.collect(DistributedCollector.Reducer<? super T,R> reducer)
Terminate the stream using a reduction performed by the given
DistributedCollector.Reducer
and return the resulting value. |
Copyright © 2018 Hazelcast, Inc.. All rights reserved.