com.gigaspaces.query.aggregators

Class AggregationSet

java.lang.Object

com.gigaspaces.query.aggregators.AggregationSet

All Implemented Interfaces:

Externalizable, Serializable

public class AggregationSet
extends Object
implements Externalizable

The set of aggregations to run for matches entries of the aggregate operation.

Since:

10.0

Author:

Niv Ingberg

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
AggregationSet()

Method Summary

Modifier and Type	Method and Description
AggregationSet	add(SpaceEntriesAggregator aggregator)
AggregationSet	average(String path) Calculates average of path values of matching entries.
AggregationSet	count() Counts matching entries.
AggregationSet	count(String path) Counts matching entries whose path is not null.
AggregationSet	distinct(DistinctAggregator aggregator)
AggregationSet	groupBy(GroupByAggregator aggregator)
AggregationSet	maxEntry(String path) Returns entry with maximum value of path of matching entries.
AggregationSet	maxValue(String path) Returns maximum value of path of matching entries.
AggregationSet	minEntry(String path) Returns entry with minimum value of path of matching entries.
AggregationSet	minValue(String path) Returns minimum value of path of matching entries.
AggregationSet	orderBy(OrderByAggregator aggregator)
void	readExternal(ObjectInput in)
AggregationSet	sum(String path) Sums values of paths of matching entries.
void	writeExternal(ObjectOutput out)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AggregationSet

public AggregationSet()

Method Detail

add

public AggregationSet add(SpaceEntriesAggregator aggregator)

count

public AggregationSet count()

Counts matching entries.

count

public AggregationSet count(String path)

Counts matching entries whose path is not null.

Parameters:

path - Path to inspect

sum

public AggregationSet sum(String path)

Sums values of paths of matching entries.

Parameters:

path - Path to sum (must be a numeric type)

average

public AggregationSet average(String path)

Calculates average of path values of matching entries.

Parameters:

path - Path to average (must be a numeric type)

maxValue

public AggregationSet maxValue(String path)

Returns maximum value of path of matching entries.

Parameters:

path - Path to inspect (must be a comparable type)

See Also:

maxEntry(String)

maxEntry

public AggregationSet maxEntry(String path)

Returns entry with maximum value of path of matching entries.

Parameters:

path - Path to inspect (must be a comparable type)

See Also:

maxValue(String)

minValue

public AggregationSet minValue(String path)

Returns minimum value of path of matching entries.

Parameters:

path - Path to inspect (must be a comparable type)

See Also:

minEntry(String)

minEntry

public AggregationSet minEntry(String path)

Returns entry with minimum value of path of matching entries.

Parameters:

path - Path to inspect (must be a comparable type)

See Also:

minEntry(String)

groupBy

public AggregationSet groupBy(GroupByAggregator aggregator)

orderBy

public AggregationSet orderBy(OrderByAggregator aggregator)

distinct

public AggregationSet distinct(DistinctAggregator aggregator)

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Throws:

IOException

ClassNotFoundException