Package | Description |
---|---|
com.hazelcast.jet.aggregate |
Contains
AggregateOperation and several its variants, as well
as a builder object for the aggregate operations. |
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> AggregateOperation1<T,LongDoubleAccumulator,Double> |
AggregateOperations.averagingDouble(DistributedToDoubleFunction<T> getDoubleValueFn)
Returns an operation that calculates the arithmetic mean of
double
values returned by the getDoubleValueFn function. |
static <T> AggregateOperation1<T,DoubleAccumulator,Double> |
AggregateOperations.summingDouble(DistributedToDoubleFunction<T> getDoubleValueFn)
Returns an operation that tracks the sum of the quantity returned by
getDoubleValueFn applied to each item in the window. |
Modifier and Type | Method and Description |
---|---|
static <T> DistributedComparator<T> |
DistributedComparator.comparingDouble(DistributedToDoubleFunction<? super T> keyExtractor) |
default DistributedComparator<T> |
DistributedComparator.thenComparingDouble(DistributedToDoubleFunction<? super T> keyExtractor) |
Modifier and Type | Method and Description |
---|---|
static <T> DistributedCollector<T,?,Double> |
DistributedCollectors.averagingDouble(DistributedToDoubleFunction<? super T> mapper)
Returns a
DistributedCollector that produces the arithmetic mean of a double-valued
function applied to the input elements. |
default DistributedDoubleStream |
DistributedStream.mapToDouble(DistributedToDoubleFunction<? super T> mapper)
Returns a
DistributedDoubleStream consisting of the results of applying the
given function to the elements of this stream. |
static <T> DistributedCollector<T,?,DoubleSummaryStatistics> |
DistributedCollectors.summarizingDouble(DistributedToDoubleFunction<? super T> mapper)
Returns a
DistributedCollector which applies an double -producing
mapping function to each input element, and returns summary statistics
for the resulting values. |
static <T> DistributedCollector<T,?,Double> |
DistributedCollectors.summingDouble(DistributedToDoubleFunction<? super T> mapper)
Returns a
DistributedCollector that produces the sum of a double-valued
function applied to the input elements. |
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.