Package | Description |
---|---|
com.hazelcast.jet.accumulator |
Classes intended to be used for accumulator objects in Jet aggregation
operations.
|
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 operation that returns the maximum item, according the given
comparator . |
static <T> AggregateOperation1<T,MutableReference<T>,T> |
AggregateOperations.minBy(DistributedComparator<? super T> comparator)
Returns an operation that returns the minimum item, according the given
comparator . |
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 being iteratively transformed by applying
the combine primitive to it and each stream item's accumulated
value, as returned from toAccValueFn . |
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.