Package | Description |
---|---|
com.hazelcast.jet.accumulator |
Classes intended to be used for accumulator objects in an
AggregateOperation . |
com.hazelcast.jet.aggregate |
Contains
AggregateOperation and several its 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(DistributedComparator<? super T> comparator)
Returns an aggregate operation that computes the maximal item according
to the given
comparator . |
static <T> AggregateOperation1<T,MutableReference<T>,T> |
AggregateOperations.minBy(DistributedComparator<? super T> comparator)
Returns an aggregate operation that computes the minimal item according
to the given
comparator . |
static <T> AggregateOperation1<T,MutableReference<T>,T> |
AggregateOperations.pickAny()
Returns an aggregate operation whose result is an arbitrary item it
observed, or
null if it observed no items. |
static <T,A> AggregateOperation1<T,MutableReference<A>,A> |
AggregateOperations.reducing(A emptyAccValue,
DistributedFunction<? super T,? extends A> toAccValueFn,
DistributedBinaryOperator<A> combineAccValuesFn,
DistributedBinaryOperator<A> deductAccValueFn)
A reducing operation maintains an accumulated value that starts out as
emptyAccValue and is iteratively transformed by applying
combineAccValuesFn to it and each stream item's accumulated
value, as returned from toAccValueFn . |
Copyright © 2018 Hazelcast, Inc.. All rights reserved.