Uses of Interface
com.hazelcast.aggregation.Aggregator

Packages that use Aggregator

Package	Description
com.hazelcast.aggregation	Contains classes related to aggregations.
com.hazelcast.jet.aggregate	Contains AggregateOperation and its several variants, as well as a builder object for the aggregate operations.
com.hazelcast.map	Contains Hazelcast map module classes.

Uses of Aggregator in com.hazelcast.aggregation

Methods in com.hazelcast.aggregation that return Aggregator

Modifier and Type	Method	Description
static <I> Aggregator<I,BigDecimal>	Aggregators.bigDecimalAvg()
static <I> Aggregator<I,BigDecimal>	Aggregators.bigDecimalAvg(String attributePath)
static <I> Aggregator<I,BigDecimal>	Aggregators.bigDecimalMax()
static <I> Aggregator<I,BigDecimal>	Aggregators.bigDecimalMax(String attributePath)
static <I> Aggregator<I,BigDecimal>	Aggregators.bigDecimalMin()
static <I> Aggregator<I,BigDecimal>	Aggregators.bigDecimalMin(String attributePath)
static <I> Aggregator<I,BigDecimal>	Aggregators.bigDecimalSum()
static <I> Aggregator<I,BigDecimal>	Aggregators.bigDecimalSum(String attributePath)
static <I> Aggregator<I,BigDecimal>	Aggregators.bigIntegerAvg()
static <I> Aggregator<I,BigDecimal>	Aggregators.bigIntegerAvg(String attributePath)
static <I> Aggregator<I,BigInteger>	Aggregators.bigIntegerMax()
static <I> Aggregator<I,BigInteger>	Aggregators.bigIntegerMax(String attributePath)
static <I> Aggregator<I,BigInteger>	Aggregators.bigIntegerMin()
static <I> Aggregator<I,BigInteger>	Aggregators.bigIntegerMin(String attributePath)
static <I> Aggregator<I,BigInteger>	Aggregators.bigIntegerSum()
static <I> Aggregator<I,BigInteger>	Aggregators.bigIntegerSum(String attributePath)
static <I, R extends Comparable> Aggregator<I,R>	Aggregators.comparableMax()
static <I, R extends Comparable> Aggregator<I,R>	Aggregators.comparableMax(String attributePath)
static <I, R extends Comparable> Aggregator<I,R>	Aggregators.comparableMin()
static <I, R extends Comparable> Aggregator<I,R>	Aggregators.comparableMin(String attributePath)
static <I> Aggregator<I,Long>	Aggregators.count()
static <I> Aggregator<I,Long>	Aggregators.count(String attributePath)
static <I, R> Aggregator<I,Set<R>>	Aggregators.distinct()
static <I, R> Aggregator<I,Set<R>>	Aggregators.distinct(String attributePath)
static <I> Aggregator<I,Double>	Aggregators.doubleAvg()
static <I> Aggregator<I,Double>	Aggregators.doubleAvg(String attributePath)
static <I> Aggregator<I,Double>	Aggregators.doubleMax()
static <I> Aggregator<I,Double>	Aggregators.doubleMax(String attributePath)
static <I> Aggregator<I,Double>	Aggregators.doubleMin()
static <I> Aggregator<I,Double>	Aggregators.doubleMin(String attributePath)
static <I> Aggregator<I,Double>	Aggregators.doubleSum()
static <I> Aggregator<I,Double>	Aggregators.doubleSum(String attributePath)
static <I> Aggregator<I,Long>	Aggregators.fixedPointSum()
static <I> Aggregator<I,Long>	Aggregators.fixedPointSum(String attributePath)
static <I> Aggregator<I,Double>	Aggregators.floatingPointSum()
static <I> Aggregator<I,Double>	Aggregators.floatingPointSum(String attributePath)
static <I> Aggregator<I,Double>	Aggregators.integerAvg()
static <I> Aggregator<I,Double>	Aggregators.integerAvg(String attributePath)
static <I> Aggregator<I,Integer>	Aggregators.integerMax()
static <I> Aggregator<I,Integer>	Aggregators.integerMax(String attributePath)
static <I> Aggregator<I,Integer>	Aggregators.integerMin()
static <I> Aggregator<I,Integer>	Aggregators.integerMin(String attributePath)
static <I> Aggregator<I,Long>	Aggregators.integerSum()
static <I> Aggregator<I,Long>	Aggregators.integerSum(String attributePath)
static <I> Aggregator<I,Double>	Aggregators.longAvg()
static <I> Aggregator<I,Double>	Aggregators.longAvg(String attributePath)
static <I> Aggregator<I,Long>	Aggregators.longMax()
static <I> Aggregator<I,Long>	Aggregators.longMax(String attributePath)
static <I> Aggregator<I,Long>	Aggregators.longMin()
static <I> Aggregator<I,Long>	Aggregators.longMin(String attributePath)
static <I> Aggregator<I,Long>	Aggregators.longSum()
static <I> Aggregator<I,Long>	Aggregators.longSum(String attributePath)
static <I> Aggregator<I,I>	Aggregators.maxBy(String attributePath)
static <I> Aggregator<I,I>	Aggregators.minBy(String attributePath)
static <I> Aggregator<I,Double>	Aggregators.numberAvg()
static <I> Aggregator<I,Double>	Aggregators.numberAvg(String attributePath)

Methods in com.hazelcast.aggregation with parameters of type Aggregator

Modifier and Type	Method	Description
void	Aggregator.combine(Aggregator aggregator)	Incorporates the intermediary result of the given aggregator to this instance of the aggregator.

Uses of Aggregator in com.hazelcast.jet.aggregate

Methods in com.hazelcast.jet.aggregate that return Aggregator

Modifier and Type	Method	Description
static <T, A, R> Aggregator<T,R>	AggregateOperations.toAggregator(AggregateOperation1<? super T,A,? extends R> aggrOp)	Adapts this aggregate operation to be used for IMap.aggregate(Aggregator) calls.

Uses of Aggregator in com.hazelcast.map

Methods in com.hazelcast.map with parameters of type Aggregator

Modifier and Type	Method	Description
<R> R	IMap.aggregate(Aggregator<? super Map.Entry<K,V>,R> aggregator)	Applies the aggregation logic on all map entries and returns the result
<R> R	IMap.aggregate(Aggregator<? super Map.Entry<K,V>,R> aggregator, Predicate<K,V> predicate)	Applies the aggregation logic on map entries filtered with the Predicated and returns the result