Package | Description |
---|---|
com.hazelcast.jet.function |
Serializable variants of functional interfaces from
java.util.function . |
com.hazelcast.jet.stream |
java.util.stream implementation using Hazelcast Jet
|
Modifier and Type | Method and Description |
---|---|
static <T> DistributedComparator<T> |
DistributedComparator.comparingInt(DistributedToIntFunction<? super T> keyExtractor) |
default DistributedComparator<T> |
DistributedComparator.thenComparingInt(DistributedToIntFunction<? super T> keyExtractor) |
Modifier and Type | Method and Description |
---|---|
static <T> DistributedCollector<T,?,Double> |
DistributedCollectors.averagingInt(DistributedToIntFunction<? super T> mapper)
Returns a
DistributedCollector that produces the arithmetic mean of an integer-valued
function applied to the input elements. |
default DistributedIntStream |
DistributedStream.mapToInt(DistributedToIntFunction<? super T> mapper)
Returns an
DistributedIntStream consisting of the results of applying the
given function to the elements of this stream. |
static <T> DistributedCollector<T,?,IntSummaryStatistics> |
DistributedCollectors.summarizingInt(DistributedToIntFunction<? super T> mapper)
Returns a
DistributedCollector which applies an int -producing
mapping function to each input element, and returns summary statistics
for the resulting values. |
static <T> DistributedCollector<T,?,Integer> |
DistributedCollectors.summingInt(DistributedToIntFunction<? super T> mapper)
Returns a
DistributedCollector that produces the sum of a integer-valued
function applied to the input elements. |
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.