Uses of Class
com.hazelcast.jet.accumulator.MutableReference
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. |
-
Uses of MutableReference in com.hazelcast.jet.accumulator
Methods in com.hazelcast.jet.accumulator that return MutableReference Modifier and Type Method Description MutableReference
MutableReference. set(T value)
Sets the value as given. -
Uses of MutableReference in com.hazelcast.jet.aggregate
Methods in com.hazelcast.jet.aggregate that return types with arguments of type MutableReference Modifier and Type Method 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 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> AggregateOperation1<T,MutableReference<T>,T>
AggregateOperations. pickAny()
Returns an aggregate operation whose result is an arbitrary item it observed, ornull
if it observed no items.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
.