Uses of Class
com.hazelcast.aggregation.Aggregator

Packages that use Aggregator

Package	Description
com.hazelcast.aggregation	Contains classes related to aggregations.
com.hazelcast.aggregation.impl
com.hazelcast.client.impl.protocol.task.map	Client protocol tasks implementations for map
com.hazelcast.client.proxy	This package contains client side proxy implementations of the different Hazelcast data structures and operation types
com.hazelcast.core	Provides core API interfaces/classes.
com.hazelcast.map.impl.proxy	Contains map proxy implementation and support classes.
com.hazelcast.map.impl.query

Uses of Aggregator in com.hazelcast.aggregation

Methods in com.hazelcast.aggregation that return Aggregator

Modifier and Type	Method and 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,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 and Description
abstract 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.aggregation.impl

Subclasses of Aggregator in com.hazelcast.aggregation.impl

Modifier and Type	Class and Description
class	AbstractAggregator<I,R> Abstract class providing convenience for concrete implementations of an Aggregator It also provides the extract() method that enables extracting values of the given attributePath from the input.
class	BigDecimalAverageAggregator<I>
class	BigDecimalSumAggregator<I>
class	BigIntegerAverageAggregator<I>
class	BigIntegerSumAggregator<I>
class	CountAggregator<I>
class	DistinctValuesAggregator<I,R>
class	DoubleAverageAggregator<I>
class	DoubleSumAggregator<I>
class	FixedSumAggregator<I>
class	FloatingPointSumAggregator<I>
class	IntegerAverageAggregator<I>
class	IntegerSumAggregator<I>
class	LongAverageAggregator<I>
class	LongSumAggregator<I>
class	MaxAggregator<I,R extends Comparable>
class	MinAggregator<I,R extends Comparable>
class	NumberAverageAggregator<I>

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

Modifier and Type	Method and Description
void	LongAverageAggregator.combine(Aggregator aggregator)
void	NumberAverageAggregator.combine(Aggregator aggregator)
void	FloatingPointSumAggregator.combine(Aggregator aggregator)
void	BigIntegerSumAggregator.combine(Aggregator aggregator)
void	IntegerSumAggregator.combine(Aggregator aggregator)
void	BigDecimalAverageAggregator.combine(Aggregator aggregator)
void	DoubleSumAggregator.combine(Aggregator aggregator)
void	BigDecimalSumAggregator.combine(Aggregator aggregator)
void	BigIntegerAverageAggregator.combine(Aggregator aggregator)
void	CountAggregator.combine(Aggregator aggregator)
void	FixedSumAggregator.combine(Aggregator aggregator)
void	MaxAggregator.combine(Aggregator aggregator)
void	DistinctValuesAggregator.combine(Aggregator aggregator)
void	LongSumAggregator.combine(Aggregator aggregator)
void	MinAggregator.combine(Aggregator aggregator)
void	IntegerAverageAggregator.combine(Aggregator aggregator)
void	DoubleAverageAggregator.combine(Aggregator aggregator)

Uses of Aggregator in com.hazelcast.client.impl.protocol.task.map

Methods in com.hazelcast.client.impl.protocol.task.map that return Aggregator

Modifier and Type	Method and Description
protected Aggregator<?,?>	DefaultMapProjectMessageTask.getAggregator()
protected Aggregator<?,?>	MapAggregateWithPredicateMessageTask.getAggregator()
protected abstract Aggregator<?,?>	AbstractMapQueryMessageTask.getAggregator()
protected Aggregator<?,?>	DefaultMapQueryMessageTask.getAggregator()
protected Aggregator<?,?>	MapAggregateMessageTask.getAggregator()

Uses of Aggregator in com.hazelcast.client.proxy

Methods in com.hazelcast.client.proxy with parameters of type Aggregator

Modifier and Type	Method and Description
<R> R	ClientMapProxy.aggregate(Aggregator<Map.Entry<K,V>,R> aggregator)
<R> R	ClientMapProxy.aggregate(Aggregator<Map.Entry<K,V>,R> aggregator, Predicate<K,V> predicate)

Uses of Aggregator in com.hazelcast.core

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

Modifier and Type	Method and Description
<R> R	IMap.aggregate(Aggregator<Map.Entry<K,V>,R> aggregator) Applies the aggregation logic on all map entries and returns the result
<R> R	IMap.aggregate(Aggregator<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

Uses of Aggregator in com.hazelcast.map.impl.proxy

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

Modifier and Type	Method and Description
<R> R	MapProxyImpl.aggregate(Aggregator<Map.Entry<K,V>,R> aggregator)
<R> R	MapProxyImpl.aggregate(Aggregator<Map.Entry<K,V>,R> aggregator, Predicate<K,V> predicate)

Uses of Aggregator in com.hazelcast.map.impl.query

Methods in com.hazelcast.map.impl.query that return Aggregator

Modifier and Type	Method and Description
Aggregator	Query.getAggregator()
<R> Aggregator<?,R>	AggregationResult.getAggregator()

Methods in com.hazelcast.map.impl.query that return types with arguments of type Aggregator

Modifier and Type	Method and Description
protected Collection<Aggregator>	ParallelAccumulationExecutor.accumulateParallel(Aggregator aggregator, Collection<QueryableEntry> entries)

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

Modifier and Type	Method and Description
protected Collection<Aggregator>	ParallelAccumulationExecutor.accumulateParallel(Aggregator aggregator, Collection<QueryableEntry> entries)
Query.QueryBuilder	Query.QueryBuilder.aggregator(Aggregator aggregator)
AggregationResult	CallerRunsAccumulationExecutor.execute(Aggregator aggregator, Collection<QueryableEntry> entries, Collection<Integer> partitionIds)
AggregationResult	ParallelAccumulationExecutor.execute(Aggregator aggregator, Collection<QueryableEntry> entries, Collection<Integer> partitionIds)
AggregationResult	AccumulationExecutor.execute(Aggregator aggregator, Collection<QueryableEntry> entries, Collection<Integer> partitionIds)

Constructors in com.hazelcast.map.impl.query with parameters of type Aggregator

Constructor and Description
AggregationResult(Aggregator aggregator)
Query(String mapName, Predicate predicate, IterationType iterationType, Aggregator aggregator, Projection projection)