| 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.