com.hazelcast.jet.stream

Class DistributedCollectors

java.lang.Object

com.hazelcast.jet.stream.DistributedCollectors

public abstract class DistributedCollectors
extends Object

Serializable variants of java.util.stream.Collectors.

Constructor Summary

Constructors

Constructor and Description
DistributedCollectors()

Method Summary

Modifier and Type	Method and Description
static <T,A,R> DistributedCollector<T,A,R>	aggregating(AggregateOperation1<T,A,R> aggregateOp) Returns a collector which performs a distributed aggregation on all the input values using the given AggregateOperation1.
static <T> DistributedCollector<T,?,Double>	averagingDouble(DistributedToDoubleFunction<? super T> mapper) Serializable variant of java.util.stream.Collectors#averagingDouble(ToDoubleFunction)
static <T> DistributedCollector<T,?,Double>	averagingInt(DistributedToIntFunction<? super T> mapper) Serializable variant of java.util.stream.Collectors#averagingInt(ToIntFunction)
static <T> DistributedCollector<T,?,Double>	averagingLong(DistributedToLongFunction<? super T> mapper) Serializable variant of java.util.stream.Collectors#averagingLong(ToLongFunction)
static <T,A,I,R> DistributedCollector<T,A,R>	collectingAndThen(DistributedCollector<T,A,I> downstream, DistributedFunction<I,R> finisher) Serializable variant of {@link Collectors#collectingAndThen(Collector, Function) java.util.stream.Collectors#collectingAndThen(Collector, Function)
static <T> DistributedCollector<T,?,Long>	counting() Serializable variant of java.util.stream.Collectors#counting()
static <T,K> DistributedCollector<T,?,Map<K,List<T>>>	groupingBy(DistributedFunction<? super T,? extends K> classifier) Serializable variant of java.util.stream.Collectors#groupingBy(Function)
static <T,K,A,D> DistributedCollector<T,?,Map<K,D>>	groupingBy(DistributedFunction<? super T,? extends K> classifier, DistributedCollector<? super T,A,D> downstream) Serializable variant of java.util.stream.Collectors#groupingBy(Function, Collector)
static <T,K,R,A,M extends Map<K,R>> DistributedCollector<T,?,M>	groupingBy(DistributedFunction<? super T,? extends K> classifier, DistributedSupplier<M> mapFactory, DistributedCollector<? super T,A,R> downstream) Serializable variant of java.util.stream.Collectors#groupingBy(Function, Supplier, Collector)
static <T,K> DistributedCollector.Reducer<T,ICacheJet<K,List<T>>>	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>>	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>>>	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>>	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 DistributedCollector<CharSequence,?,String>	joining() Serializable variant of java.util.stream.Collectors#joining()
static DistributedCollector<CharSequence,?,String>	joining(CharSequence delimiter) Serializable variant of java.util.stream.Collectors#joining(CharSequence)
static DistributedCollector<CharSequence,?,String>	joining(CharSequence delimiter, CharSequence prefix, CharSequence suffix) Serializable variant of java.util.stream.Collectors#joining(CharSequence, CharSequence, CharSequence)
static <T,U,A,R> DistributedCollector<T,?,R>	mapping(DistributedFunction<? super T,? extends U> mapper, DistributedCollector<? super U,A,R> downstream) Serializable variant of java.util.stream.Collectors#mapping(Function, Collector)
static <T> DistributedCollector<T,?,Optional<T>>	maxBy(DistributedComparator<? super T> comparator) Serializable variant of java.util.stream.Collectors#maxBy(Comparator)
static <T> DistributedCollector<T,?,Optional<T>>	minBy(DistributedComparator<? super T> comparator) Serializable variant of java.util.stream.Collectors#minBy(Comparator)
static <T> Collector<T,?,Map<Boolean,List<T>>>	partitioningBy(DistributedPredicate<? super T> predicate) Serializable variant of java.util.stream.Collectors#partitioningBy(Predicate)
static <T,D,A> Collector<T,?,Map<Boolean,D>>	partitioningBy(DistributedPredicate<? super T> predicate, DistributedCollector<? super T,A,D> downstream) Serializable variant of java.util.stream.Collectors#partitioningBy(Predicate, Collector)
static <T> DistributedCollector<T,?,Optional<T>>	reducing(DistributedBinaryOperator<T> op) Serializable variant of java.util.stream.Collectors#reducing(BinaryOperator)
static <T> DistributedCollector<T,?,T>	reducing(T identity, DistributedBinaryOperator<T> op) Serializable variant of Collectors.reducing(Object, BinaryOperator) java.util.stream.Collectors#reducing(Object, BinaryOperator)}
static <T,U> DistributedCollector<T,?,U>	reducing(U identity, DistributedFunction<? super T,? extends U> mapper, DistributedBinaryOperator<U> op) Serializable variant of java.util.stream.Collectors#reducing(Object, Function, BinaryOperator)
static <T> DistributedCollector<T,?,DoubleSummaryStatistics>	summarizingDouble(DistributedToDoubleFunction<? super T> mapper) Serializable variant of java.util.stream.Collectors#summarizingDouble(ToDoubleFunction)
static <T> DistributedCollector<T,?,IntSummaryStatistics>	summarizingInt(DistributedToIntFunction<? super T> mapper) Serializable variant of java.util.stream.Collectors#summarizingInt(ToIntFunction)
static <T> DistributedCollector<T,?,LongSummaryStatistics>	summarizingLong(DistributedToLongFunction<? super T> mapper) Serializable variant of java.util.stream.Collectors#summarizingLong(ToLongFunction)
static <T> DistributedCollector<T,?,Double>	summingDouble(DistributedToDoubleFunction<? super T> mapper) Serializable variant of java.util.stream.Collectors#summingDouble(ToDoubleFunction)
static <T> DistributedCollector<T,?,Integer>	summingInt(DistributedToIntFunction<? super T> mapper) Serializable variant of java.util.stream.Collectors#summingInt(ToIntFunction)
static <T> DistributedCollector<T,?,Long>	summingLong(DistributedToLongFunction<? super T> mapper) Serializable variant of java.util.stream.Collectors#summingLong(ToLongFunction)
static <T,C extends Collection<T>> DistributedCollector<T,?,C>	toCollection(DistributedSupplier<C> collectionSupplier) Serializable variant of java.util.stream.Collectors#toCollection(Supplier)
static <K,U> DistributedCollector.Reducer<Map.Entry<K,U>,ICacheJet<K,U>>	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>>	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>>	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>>	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>>	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>>	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>>	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.
static <T> DistributedCollector<T,?,List<T>>	toList() Serializable variant of java.util.stream.Collectors#toList()
static <T,K,U> DistributedCollector<T,?,Map<K,U>>	toMap(DistributedFunction<? super T,? extends K> keyMapper, DistributedFunction<? super T,? extends U> valueMapper) Serializable variant of java.util.stream.Collectors#toMap(Function, Function)
static <T,K,U> Collector<T,?,Map<K,U>>	toMap(DistributedFunction<? super T,? extends K> keyMapper, DistributedFunction<? super T,? extends U> valueMapper, DistributedBinaryOperator<U> mergeFunction) Serializable variant of java.util.stream.Collectors#toMap(Function, Function, BinaryOperator)
static <T,K,U,M extends Map<K,U>> DistributedCollector<T,?,M>	toMap(DistributedFunction<? super T,? extends K> keyMapper, DistributedFunction<? super T,? extends U> valueMapper, DistributedBinaryOperator<U> mergeFunction, DistributedSupplier<M> mapSupplier) Serializable variant of java.util.stream.Collectors#toMap(Function, Function, BinaryOperator, Supplier)
static <T> DistributedCollector<T,?,Set<T>>	toSet() Serializable variant of java.util.stream.Collectors#toSet()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DistributedCollectors

public DistributedCollectors()

Method Detail

toCollection

public static <T,C extends Collection<T>> DistributedCollector<T,?,C> toCollection(DistributedSupplier<C> collectionSupplier)

Serializable variant of java.util.stream.Collectors#toCollection(Supplier)

toList

public static <T> DistributedCollector<T,?,List<T>> toList()

Serializable variant of java.util.stream.Collectors#toList()

toSet

public static <T> DistributedCollector<T,?,Set<T>> toSet()

Serializable variant of java.util.stream.Collectors#toSet()

joining

public static DistributedCollector<CharSequence,?,String> joining()

Serializable variant of java.util.stream.Collectors#joining()

joining

public static DistributedCollector<CharSequence,?,String> joining(CharSequence delimiter)

Serializable variant of java.util.stream.Collectors#joining(CharSequence)

joining

public static DistributedCollector<CharSequence,?,String> joining(CharSequence delimiter,
                                                                  CharSequence prefix,
                                                                  CharSequence suffix)

Serializable variant of java.util.stream.Collectors#joining(CharSequence, CharSequence, CharSequence)

mapping

public static <T,U,A,R> DistributedCollector<T,?,R> mapping(DistributedFunction<? super T,? extends U> mapper,
                                                            DistributedCollector<? super U,A,R> downstream)

Serializable variant of java.util.stream.Collectors#mapping(Function, Collector)

collectingAndThen

public static <T,A,I,R> DistributedCollector<T,A,R> collectingAndThen(DistributedCollector<T,A,I> downstream,
                                                                      DistributedFunction<I,R> finisher)

Serializable variant of {@link Collectors#collectingAndThen(Collector, Function) java.util.stream.Collectors#collectingAndThen(Collector, Function)

counting

public static <T> DistributedCollector<T,?,Long> counting()

Serializable variant of java.util.stream.Collectors#counting()

minBy

public static <T> DistributedCollector<T,?,Optional<T>> minBy(DistributedComparator<? super T> comparator)

Serializable variant of java.util.stream.Collectors#minBy(Comparator)

maxBy

public static <T> DistributedCollector<T,?,Optional<T>> maxBy(DistributedComparator<? super T> comparator)

Serializable variant of java.util.stream.Collectors#maxBy(Comparator)

summingInt

public static <T> DistributedCollector<T,?,Integer> summingInt(DistributedToIntFunction<? super T> mapper)

Serializable variant of java.util.stream.Collectors#summingInt(ToIntFunction)

summingLong

public static <T> DistributedCollector<T,?,Long> summingLong(DistributedToLongFunction<? super T> mapper)

Serializable variant of java.util.stream.Collectors#summingLong(ToLongFunction)

summingDouble

public static <T> DistributedCollector<T,?,Double> summingDouble(DistributedToDoubleFunction<? super T> mapper)

Serializable variant of java.util.stream.Collectors#summingDouble(ToDoubleFunction)

averagingInt

public static <T> DistributedCollector<T,?,Double> averagingInt(DistributedToIntFunction<? super T> mapper)

Serializable variant of java.util.stream.Collectors#averagingInt(ToIntFunction)

averagingLong

public static <T> DistributedCollector<T,?,Double> averagingLong(DistributedToLongFunction<? super T> mapper)

Serializable variant of java.util.stream.Collectors#averagingLong(ToLongFunction)

averagingDouble

public static <T> DistributedCollector<T,?,Double> averagingDouble(DistributedToDoubleFunction<? super T> mapper)

Serializable variant of java.util.stream.Collectors#averagingDouble(ToDoubleFunction)

reducing

public static <T> DistributedCollector<T,?,T> reducing(T identity,
                                                       DistributedBinaryOperator<T> op)

Serializable variant of Collectors.reducing(Object, BinaryOperator) java.util.stream.Collectors#reducing(Object, BinaryOperator)}

reducing

public static <T> DistributedCollector<T,?,Optional<T>> reducing(DistributedBinaryOperator<T> op)

Serializable variant of java.util.stream.Collectors#reducing(BinaryOperator)

reducing

public static <T,U> DistributedCollector<T,?,U> reducing(U identity,
                                                         DistributedFunction<? super T,? extends U> mapper,
                                                         DistributedBinaryOperator<U> op)

Serializable variant of java.util.stream.Collectors#reducing(Object, Function, BinaryOperator)

groupingBy

public static <T,K> DistributedCollector<T,?,Map<K,List<T>>> groupingBy(DistributedFunction<? super T,? extends K> classifier)

Serializable variant of java.util.stream.Collectors#groupingBy(Function)

groupingBy

public static <T,K,A,D> DistributedCollector<T,?,Map<K,D>> groupingBy(DistributedFunction<? super T,? extends K> classifier,
                                                                      DistributedCollector<? super T,A,D> downstream)

Serializable variant of java.util.stream.Collectors#groupingBy(Function, Collector)

groupingBy

public static <T,K,R,A,M extends Map<K,R>> DistributedCollector<T,?,M> groupingBy(DistributedFunction<? super T,? extends K> classifier,
                                                                                  DistributedSupplier<M> mapFactory,
                                                                                  DistributedCollector<? super T,A,R> downstream)

Serializable variant of java.util.stream.Collectors#groupingBy(Function, Supplier, Collector)

partitioningBy

public static <T> Collector<T,?,Map<Boolean,List<T>>> partitioningBy(DistributedPredicate<? super T> predicate)

Serializable variant of java.util.stream.Collectors#partitioningBy(Predicate)

partitioningBy

public static <T,D,A> Collector<T,?,Map<Boolean,D>> partitioningBy(DistributedPredicate<? super T> predicate,
                                                                   DistributedCollector<? super T,A,D> downstream)

Serializable variant of java.util.stream.Collectors#partitioningBy(Predicate, Collector)

toMap

public static <T,K,U> DistributedCollector<T,?,Map<K,U>> toMap(DistributedFunction<? super T,? extends K> keyMapper,
                                                               DistributedFunction<? super T,? extends U> valueMapper)

Serializable variant of java.util.stream.Collectors#toMap(Function, Function)

toMap

public static <T,K,U> Collector<T,?,Map<K,U>> toMap(DistributedFunction<? super T,? extends K> keyMapper,
                                                    DistributedFunction<? super T,? extends U> valueMapper,
                                                    DistributedBinaryOperator<U> mergeFunction)

Serializable variant of java.util.stream.Collectors#toMap(Function, Function, BinaryOperator)

toMap

public static <T,K,U,M extends Map<K,U>> DistributedCollector<T,?,M> toMap(DistributedFunction<? super T,? extends K> keyMapper,
                                                                           DistributedFunction<? super T,? extends U> valueMapper,
                                                                           DistributedBinaryOperator<U> mergeFunction,
                                                                           DistributedSupplier<M> mapSupplier)

Serializable variant of java.util.stream.Collectors#toMap(Function, Function, BinaryOperator, Supplier)

summarizingInt

public static <T> DistributedCollector<T,?,IntSummaryStatistics> summarizingInt(DistributedToIntFunction<? super T> mapper)

Serializable variant of java.util.stream.Collectors#summarizingInt(ToIntFunction)

summarizingLong

public static <T> DistributedCollector<T,?,LongSummaryStatistics> summarizingLong(DistributedToLongFunction<? super T> mapper)

Serializable variant of java.util.stream.Collectors#summarizingLong(ToLongFunction)

summarizingDouble

public static <T> DistributedCollector<T,?,DoubleSummaryStatistics> summarizingDouble(DistributedToDoubleFunction<? super T> mapper)

Serializable variant of java.util.stream.Collectors#summarizingDouble(ToDoubleFunction)

aggregating

public static <T,A,R> DistributedCollector<T,A,R> aggregating(AggregateOperation1<T,A,R> aggregateOp)

Returns a collector which performs a distributed aggregation on all the input values using the given AggregateOperation1.

toIMap

public static <T,K,U> DistributedCollector.Reducer<T,IMapJet<K,U>> 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. The stream expression will return the IMapJet in question.

toIMap

public static <K,U> DistributedCollector.Reducer<Map.Entry<K,U>,IMapJet<K,U>> 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.

This collector expects to receive Map.Entrys and it will put them as key/value pairs to the target map.

toIMap

public static <T,K,U> DistributedCollector.Reducer<T,IMapJet<K,U>> 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.

toICache

public static <T,K,U> DistributedCollector.Reducer<T,ICacheJet<K,U>> 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.

toICache

public static <K,U> DistributedCollector.Reducer<Map.Entry<K,U>,ICacheJet<K,U>> 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.

toICache

public static <T,K,U> DistributedCollector.Reducer<T,ICacheJet<K,U>> 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.

toIList

public static <T> DistributedCollector.Reducer<T,IListJet<T>> 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.

groupingByToIMap

public static <T,K> DistributedCollector.Reducer<T,IMapJet<K,List<T>>> 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.

groupingByToIMap

public static <T,K,A,D> DistributedCollector.Reducer<T,IMapJet<K,D>> 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. The downstream collector you provide will produce the value to be stored under each grouping key. The value must be serializable.

groupingByToICache

public static <T,K> DistributedCollector.Reducer<T,ICacheJet<K,List<T>>> 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.

groupingByToICache

public static <T,K,A,D> DistributedCollector.Reducer<T,ICacheJet<K,D>> 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. The downstream collector you provide will produce the value to be stored under each grouping key. The value must be serializable.