Package | Description |
---|---|
com.hazelcast.jet.accumulator |
Classes intended to be used for accumulator objects in an
AggregateOperation . |
com.hazelcast.jet.aggregate |
Contains
AggregateOperation and its several variants, as well
as a builder object for the aggregate operations. |
Modifier and Type | Method and Description |
---|---|
MutableReference |
MutableReference.set(T value)
Sets the value as given.
|
Modifier and Type | Method and Description |
---|---|
static <T> AggregateOperation1<T,MutableReference<T>,T> |
AggregateOperations.maxBy(ComparatorEx<? super T> comparator)
Returns an aggregate operation that computes the greatest item according
to the given
comparator . |
static <T> AggregateOperation1<T,MutableReference<T>,T> |
AggregateOperations.minBy(ComparatorEx<? super T> comparator)
Returns an aggregate operation that computes the least item according to
the given
comparator . |
static <T,A> AggregateOperation1<T,MutableReference<A>,A> |
AggregateOperations.reducing(A emptyAccValue,
FunctionEx<? super T,? extends A> toAccValueFn,
BinaryOperatorEx<A> combineAccValuesFn,
BinaryOperatorEx<A> deductAccValueFn)
Returns an aggregate operation that constructs the result through the
process of immutable reduction:
The initial accumulated value is
emptyAccValue . |
Copyright © 2022 Hazelcast, Inc.. All rights reserved.