Package com.tangosol.util.aggregator

package com.tangosol.util.aggregator
Contains concrete InvocableMap.EntryAggregator implementations.
  • 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.
    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.
    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.