Namespace Tangosol.Util.Aggregator

Classes

AbstractAggregator

Abstract base class implementation of IEntryAggregator that supports parallel aggregation.

AbstractComparableAggregator

Abstract aggregator that processes values extracted from a set of entries in a cache, with knowledge of how to compare those values.

AbstractDecimalAggregator

Abstract aggregator that processes IComparable values extracted from a set of entries in a IDictionary and returns a result in a form of a decimal value.

AbstractDoubleAggregator

Abstract aggregator that processes numeric values extracted from a collection of entries in a cache.

AbstractLongAggregator

Abstract aggregator that processes numeric values extracted from a collection of entries in a cache.

ComparableMax

Calculates a maximum among values extracted from a set of entries in a cache.

ComparableMin

Calculates a minimum among values extracted from a set of entries in a cache.

CompositeAggregator

CompositeAggregator provides an ability to execute a collection of aggregators against the same subset of the entries in an IInvocableCache, resulting in a list of corresponding aggregation results.

CompositeAggregator.Parallel

Parallel implementation of the CompositeAggregator.

Count

Calculates a number of values in an entries collection.

DecimalAverage

Calculates an average for values of any numberic type extracted from a set of entries in a IDictionary in a form of a decimal value.

DecimalMax

Calculates a maximum of numeric values extracted from a set of entries in a IDictionary in a form of a decimal value.

DecimalMin

Calculates a minimum of numeric values extracted from a set of entries in a IDictionary in a form of a decimal value.

DecimalSum

Calculates a minimum of numeric values extracted from a set of entries in a IDictionary in a form of a decimal value.

DistinctValues

Return the ICollection of unique values extracted from a collection of entries in a cache.

DoubleAverage

Calculates an average for values of any numberic type extracted from a collection of entries in a cache.

DoubleMax

Calculates a maximum of numeric values extracted from a collection of entries in a cache.

DoubleMin

Calculates a minimum of numeric values extracted from a collection of entries in a cache.

DoubleSum

Sums up numeric values extracted from a collection of entries in a cache.

GroupAggregator

The GroupAggregator provides an ability to split a subset of entries in an IInvocableCache into a collection of non-intersecting subsets and then aggregate them separately and independently.

GroupAggregator.Parallel

Parallel implementation of the GroupAggregator.

LongMax

Calculates a maximum of numeric values extracted from a collection of entries in a cache.

LongMin

Calculates a minimum of numeric values extracted from a collection of entries in a cache.

LongSum

Sums up numeric values extracted from a collection of entries in a cache.

PriorityAggregator

PriorityAggregator is used to explicitly control the scheduling priority and timeouts for execution of IEntryAggregator -based methods.

QueryRecorder

This parallel aggregator used to produce a {@link com.tangosol.util.QueryRecord} object that contains an estimated or actual cost of the query execution for a given filter.

For example, the following code will return a QueryPlan, containing the estimated query cost and corresponding execution steps.

ReducerAggregator

The ReducerAggregator will return a portion of value attributes based on the provided ValueExtractor, instead of returning the complete set of values.

TopNAggregator

TopNAggregator is a ParallelAwareAggregator that aggregates the top N extracted values into an array. The extracted values must not be null, but do not need to be unique.

TopNAggregator.ExtractingConverter

A value-extracting converter.

TopNAggregator.PartialResult

The sorted partial result.

Enums

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.