Package com.tangosol.util.aggregator

Contains concrete InvocableMap.EntryAggregator implementations.

Class Summary

Class	Description
AbstractAggregator<K,V,T,E,R>	Abstract base class implementation of InvocableMap.EntryAggregator that supports streaming aggregation.
AbstractAsynchronousAggregator<K,V,P,R>	Abstract base class for asynchronous entry aggregators.
AbstractBigDecimalAggregator<T>	Abstract aggregator that processes Number values extracted from a set of entries in a Map and returns a result in a form of a BigDecimal value.
AbstractComparableAggregator<T,R>	Abstract aggregator that processes values extracted from a set of entries in a Map, with knowledge of how to compare those values.
AbstractDoubleAggregator<T>	Abstract aggregator that processes numeric values extracted from a set of entries in a Map.
AbstractLongAggregator<T>	Abstract aggregator that processes numeric values extracted from a set of entries in a Map.
AsynchronousAggregator<K,V,P,R>	A marker EntryAggregator wrapper class that allows for an asynchronous invocation of the underlying aggregator.
BigDecimalAverage<T>	Calculates an average for values of any numeric type extracted from a set of entries in a Map in a form of a BigDecimal value.
BigDecimalMax<T>	Calculates a maximum of numeric values extracted from a set of entries in a Map in a form of a BigDecimal value.
BigDecimalMin<T>	Calculates a minimum of numeric values extracted from a set of entries in a Map in a form of a BigDecimal value.
BigDecimalSum<T>	Calculates an sum for values of any numberic type extracted from a set of entries in a Map in a form of a BigDecimal value.
ComparableMax<T,R>	Calculates a maximum among values extracted from a set of entries in a Map.
ComparableMin<T,R>	Calculates a minimum among values extracted from a set of entries in a Map.
CompositeAggregator<K,V>	CompositeAggregator provides an ability to execute a collection of aggregators against the same subset of the entries in an InvocableMap, resulting in a list of corresponding aggregation results.
CompositeAggregator.Parallel	Deprecated. As of Coherence 12.2.1.
Count<K,V>	Calculates a number of values in an entry set.
DistinctValues<K,V,T,E>	Return the set of unique values extracted from a set of entries in a Map.
DoubleAverage<T>	Calculates an average for values of any numeric type extracted from a set of entries in a Map.
DoubleMax<T>	Calculates a maximum of numeric values extracted from a set of entries in a Map.
DoubleMin<T>	Calculates a minimum of numeric values extracted from a set of entries in a Map.
DoubleSum<T>	Sums up numeric values extracted from a set of entries in a Map.
GroupAggregator<K,V,T,E,R>	The GroupAggregator provides an ability to split a subset of entries in an InvocableMap into a collection of non-intersecting subsets and then aggregate them separately and independently.
GroupAggregator.Parallel<K,V,T,E,R>	Deprecated. As of Coherence 12.2.1.
LongMax<T>	Calculates a maximum of numeric values extracted from a set of entries in a Map.
LongMin<T>	Calculates a minimum of numeric values extracted from a set of entries in a Map.
LongSum<T>	Sums up numeric values extracted from a set of entries in a Map.
PriorityAggregator<K,V,P,R>	PriorityAggregator is used to explicitly control the scheduling priority and timeouts for execution of EntryAggregator-based methods.
QueryRecorder<K,V>	This aggregator is used to produce a QueryRecord object that contains an estimated or actual cost of the query execution for a given filter.
ReducerAggregator<K,V,T,E>	The ReducerAggregator is used to implement functionality similar to CacheMap.getAll(Collection) API.
ScriptAggregator<K,V,P,R>	ScriptAggregator is a InvocableMap.StreamingAggregator that wraps a script written in one of the languages supported by Graal VM.
TopNAggregator<K,V,T,E>	TopNAggregator is a ParallelAwareAggregator that aggregates the top N extracted values into an array.
TopNAggregator.PartialResult<E>	The sorted partial result.

Enum Summary

Enum	Description
QueryRecorder.RecordType	RecordType enum specifies whether the QueryRecorder should be used to produce a QueryRecord object that contains an estimated or an actual cost of the query execution.