Uses of Class
com.hazelcast.jet.accumulator.MutableReference
Package
Description
Classes intended to be used for accumulator objects in an
AggregateOperation
.Contains
AggregateOperation
and its several variants, as well
as a builder object for the aggregate operations.-
Uses of MutableReference in com.hazelcast.jet.accumulator
Modifier and TypeMethodDescriptionSets the value as given. -
Uses of MutableReference in com.hazelcast.jet.aggregate
Modifier and TypeMethodDescriptionstatic <T> AggregateOperation1<T,
MutableReference<T>, T> AggregateOperations.maxBy
(ComparatorEx<? super T> comparator) Returns an aggregate operation that computes the greatest item according to the givencomparator
.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 givencomparator
.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 isemptyAccValue
.