Uses of Interface
com.tangosol.util.InvocableMap.StreamingAggregator

Packages that use InvocableMap.StreamingAggregator

Package	Description
com.tangosol.coherence.jcache.partitionedcache	Contains classes related to partitioned cache implementation of Coherence JCache.
com.tangosol.util	Contains various generic utilities.
com.tangosol.util.aggregator	Contains concrete InvocableMap.EntryAggregator implementations.

Uses of InvocableMap.StreamingAggregator in com.tangosol.coherence.jcache.partitionedcache

Classes in com.tangosol.coherence.jcache.partitionedcache that implement InvocableMap.StreamingAggregator

Modifier and Type	Class and Description
static class	PartitionedJCacheStatistics.PartitionedCacheStatisticsAggregator Collect JCache CacheStatistics from all storage-enabled members.
static class	PartitionedJCacheStatistics.PartitionedCacheStatisticsClear Clear JCache CacheStatistics from all storage-enabled members.

Methods in com.tangosol.coherence.jcache.partitionedcache that return InvocableMap.StreamingAggregator

Modifier and Type	Method and Description
InvocableMap.StreamingAggregator	PartitionedJCacheStatistics.PartitionedCacheStatisticsAggregator.supply()
InvocableMap.StreamingAggregator	PartitionedJCacheStatistics.PartitionedCacheStatisticsClear.supply()

Uses of InvocableMap.StreamingAggregator in com.tangosol.util

Methods in com.tangosol.util that return InvocableMap.StreamingAggregator

Modifier and Type	Method and Description
static <K,V> InvocableMap.StreamingAggregator<K,V,?,Double>	Aggregators.average(String sMethod) Return an aggregator that calculates a average of the numeric values extracted from a set of entries in a Map.
static <K,V,T> InvocableMap.StreamingAggregator<K,V,?,Double>	Aggregators.average(ValueExtractor<? super T,? extends Number> extractor) Return an aggregator that calculates a average of the numeric values extracted from a set of entries in a Map.
static <K,V> InvocableMap.StreamingAggregator<K,V,?,BigDecimal>	Aggregators.bigDecimalAverage(String sMethod) Return an aggregator that calculates a average of the numeric values extracted from a set of entries in a Map.
static <K,V,T> InvocableMap.StreamingAggregator<K,V,?,BigDecimal>	Aggregators.bigDecimalAverage(ValueExtractor<? super T,? extends Number> extractor) Return an aggregator that calculates a average of the numeric values extracted from a set of entries in a Map.
static <K,V> InvocableMap.StreamingAggregator<K,V,?,BigDecimal>	Aggregators.bigDecimalMax(String sMethod) Return an aggregator that calculates a maximum of the numeric values extracted from a set of entries in a Map.
static <K,V,T> InvocableMap.StreamingAggregator<K,V,?,BigDecimal>	Aggregators.bigDecimalMax(ValueExtractor<? super T,? extends Number> extractor) Return an aggregator that calculates a maximum of the numeric values extracted from a set of entries in a Map.
static <K,V> InvocableMap.StreamingAggregator<K,V,?,BigDecimal>	Aggregators.bigDecimalMin(String sMethod) Return an aggregator that calculates a minimum of the numeric values extracted from a set of entries in a Map.
static <K,V,T> InvocableMap.StreamingAggregator<K,V,?,BigDecimal>	Aggregators.bigDecimalMin(ValueExtractor<? super T,? extends Number> extractor) Return an aggregator that calculates a minimum of the numeric values extracted from a set of entries in a Map.
static <K,V> InvocableMap.StreamingAggregator<K,V,?,BigDecimal>	Aggregators.bigDecimalSum(String sMethod) Return an aggregator that calculates a sum of the numeric values extracted from a set of entries in a Map.
static <K,V,T> InvocableMap.StreamingAggregator<K,V,?,BigDecimal>	Aggregators.bigDecimalSum(ValueExtractor<? super T,? extends Number> extractor) Return an aggregator that calculates a sum of the numeric values extracted from a set of entries in a Map.
static <K,V,T,R extends Comparable<? super R>> InvocableMap.StreamingAggregator<K,V,?,R>	Aggregators.comparableMax(String sMethod) Return an aggregator that calculates a maximum of the Comparable values extracted from a set of entries in a Map.
static <K,V,T,R extends Comparable<? super R>> InvocableMap.StreamingAggregator<K,V,?,R>	Aggregators.comparableMax(String sMethod, Comparator<? super R> comparator) Return an aggregator that calculates a maximum of the values extracted from a set of entries in a Map.
static <K,V,T,R extends Comparable<? super R>> InvocableMap.StreamingAggregator<K,V,?,R>	Aggregators.comparableMax(ValueExtractor<? super T,? extends R> extractor) Return an aggregator that calculates a maximum of the Comparable values extracted from a set of entries in a Map.
static <K,V,T,R extends Comparable<? super R>> InvocableMap.StreamingAggregator<K,V,?,R>	Aggregators.comparableMax(ValueExtractor<? super T,? extends R> extractor, Comparator<? super R> comparator) Return an aggregator that calculates a maximum of the values extracted from a set of entries in a Map.
static <K,V,R extends Comparable<? super R>> InvocableMap.StreamingAggregator<K,V,?,R>	Aggregators.comparableMin(String sMethod) Return an aggregator that calculates a minimum of the Comparable values extracted from a set of entries in a Map.
static <K,V,R extends Comparable<? super R>> InvocableMap.StreamingAggregator<K,V,?,R>	Aggregators.comparableMin(String sMethod, Comparator<? super R> comparator) Return an aggregator that calculates a minimum of the values extracted from a set of entries in a Map.
static <K,V,T,R extends Comparable<? super R>> InvocableMap.StreamingAggregator<K,V,?,R>	Aggregators.comparableMin(ValueExtractor<? super T,? extends R> extractor) Return an aggregator that calculates a minimum of the Comparable values extracted from a set of entries in a Map.
static <K,V,T,R extends Comparable<? super R>> InvocableMap.StreamingAggregator<K,V,?,R>	Aggregators.comparableMin(ValueExtractor<? super T,? extends R> extractor, Comparator<? super R> comparator) Return an aggregator that calculates a minimum of the values extracted from a set of entries in a Map.
static <K,V> InvocableMap.StreamingAggregator<K,V,?,List<?>>	Aggregators.composite(InvocableMap.EntryAggregator... aAggregator) Return an aggregator that calculates the the combined set of results from a number of aggregators.
static <K,V> InvocableMap.StreamingAggregator<K,V,Integer,Integer>	Aggregators.count() Return an aggregator that calculates the count of the entries in a Map.
static <K,V> InvocableMap.StreamingAggregator<K,V,?,Collection<V>>	Aggregators.distinctValues() Return an aggregator that calculates the set of distinct values from the entries in a Map.
static <K,V,R> InvocableMap.StreamingAggregator<K,V,?,Collection<R>>	Aggregators.distinctValues(String sMethod) Return an aggregator that calculates the set of distinct values extracted from the entries in a Map.
static <K,V,T,R> InvocableMap.StreamingAggregator<K,V,?,Collection<R>>	Aggregators.distinctValues(ValueExtractor<? super T,? extends R> extractor) Return an aggregator that calculates the set of distinct values extracted from the entries in a Map.
static <K,V> InvocableMap.StreamingAggregator<K,V,?,Double>	Aggregators.doubleMax(String sMethod) Return an aggregator that calculates a maximum of the numeric values extracted from a set of entries in a Map.
static <K,V,T> InvocableMap.StreamingAggregator<K,V,?,Double>	Aggregators.doubleMax(ValueExtractor<? super T,? extends Number> extractor) Return an aggregator that calculates a maximum of the numeric values extracted from a set of entries in a Map.
static <K,V> InvocableMap.StreamingAggregator<K,V,?,Double>	Aggregators.doubleMin(String sMethod) Return an aggregator that calculates a minimum of the numeric values extracted from a set of entries in a Map.
static <K,V,T> InvocableMap.StreamingAggregator<K,V,?,Double>	Aggregators.doubleMin(ValueExtractor<? super T,? extends Number> extractor) Return an aggregator that calculates a minimum of the numeric values extracted from a set of entries in a Map.
static <K,V> InvocableMap.StreamingAggregator<K,V,?,Double>	Aggregators.doubleSum(String sMethod) Return an aggregator that calculates a sum of the numeric values extracted from a set of entries in a Map.
static <K,V,T> InvocableMap.StreamingAggregator<K,V,?,Double>	Aggregators.doubleSum(ValueExtractor<? super T,? extends Number> extractor) Return an aggregator that calculates a sum of the numeric values extracted from a set of entries in a Map.
static <K,V,E,R> InvocableMap.StreamingAggregator<K,V,Map<E,Object>,Map<E,R>>	Aggregators.grouping(InvocableMap.EntryAggregator<K,V,R> aggregator, Filter filter, String... asNames) Create an instance of group aggregator based on a specified property or method name(s) and an InvocableMap.EntryAggregator.
static <K,V,E,R> InvocableMap.StreamingAggregator<K,V,Map<E,Object>,Map<E,R>>	Aggregators.grouping(InvocableMap.EntryAggregator<K,V,R> aggregator, String... asNames) Create an instance of group aggregator based on a specified property or method name(s) and an InvocableMap.EntryAggregator.
static <K,V,T,E,R> InvocableMap.StreamingAggregator<K,V,Map<E,Object>,Map<E,R>>	Aggregators.grouping(ValueExtractor<? super T,? extends E> extractor, InvocableMap.EntryAggregator<? super K,? super V,R> aggregator, Filter filter) Create an instance of group aggregator based on a specified property or method name(s) and an InvocableMap.EntryAggregator.
static <K,V,T,E,R> InvocableMap.StreamingAggregator<K,V,Map<E,Object>,Map<E,R>>	Aggregators.grouping(ValueExtractor<? super T,? extends E> extractor, InvocableMap.EntryAggregator<K,V,R> aggregator) Create an instance of group aggregator based on a specified property or method name(s) and an InvocableMap.EntryAggregator.
static <K,V> InvocableMap.StreamingAggregator<K,V,?,Long>	Aggregators.longMax(String sMethod) Return an aggregator that calculates a maximum of the numeric values extracted from a set of entries in a Map.
static <K,V,T> InvocableMap.StreamingAggregator<K,V,?,Long>	Aggregators.longMax(ValueExtractor<? super T,? extends Number> extractor) Return an aggregator that calculates a maximum of the numeric values extracted from a set of entries in a Map.
static <K,V> InvocableMap.StreamingAggregator<K,V,?,Long>	Aggregators.longMin(String sMethod) Return an aggregator that calculates a minimum of the numeric values extracted from a set of entries in a Map.
static <K,V,T> InvocableMap.StreamingAggregator<K,V,?,Long>	Aggregators.longMin(ValueExtractor<? super T,? extends Number> extractor) Return an aggregator that calculates a minimum of the numeric values extracted from a set of entries in a Map.
static <K,V> InvocableMap.StreamingAggregator<K,V,?,Long>	Aggregators.longSum(String sMethod) Return an aggregator that calculates a sum of the numeric values extracted from a set of entries in a Map.
static <K,V,T> InvocableMap.StreamingAggregator<K,V,?,Long>	Aggregators.longSum(ValueExtractor<? super T,? extends Number> extractor) Return an aggregator that calculates a sum of the numeric values extracted from a set of entries in a Map.
static <K,V,R extends Comparable<? super R>> InvocableMap.StreamingAggregator<K,V,?,Map<K,R>>	Aggregators.reduce(String sMethod) Return an aggregator that will return the extracted value for each entry in the map.
static <K,V,T,R extends Comparable<? super R>> InvocableMap.StreamingAggregator<K,V,?,Map<K,R>>	Aggregators.reduce(ValueExtractor<? super T,? extends R> extractor) Return an aggregator that will return the extracted value for each entry in the map.
static <K,V,P,R> InvocableMap.StreamingAggregator<K,V,P,R>	Aggregators.script(String sLanguage, String sName, int characteristics, Object... aoArgs) Return an aggregator that is implemented in a script using the specified language.
static <K,V,P,R> InvocableMap.StreamingAggregator<K,V,P,R>	Aggregators.script(String sLanguage, String sName, Object... aoArgs) Return an aggregator that is implemented in a script using the specified language.
InvocableMap.StreamingAggregator<K,V,P,R>	InvocableMap.StreamingAggregator.supply() Create a new instance of this aggregator.
static <K,V,T,R extends Comparable<? super R>> InvocableMap.StreamingAggregator<K,V,?,R[]>	Aggregators.topN(String sMethod, Comparator<? super R> comparator, int cResults) Return an aggregator that calculates the top n of the values extracted from a set of entries in a Map.
static <K,V,T,R extends Comparable<? super R>> InvocableMap.StreamingAggregator<K,V,?,R[]>	Aggregators.topN(String sMethod, int cResults) Return an aggregator that calculates the top n of the Comparable values extracted from a set of entries in a Map.
static <K,V,T,R extends Comparable<? super R>> InvocableMap.StreamingAggregator<K,V,?,R[]>	Aggregators.topN(ValueExtractor<? super T,? extends R> extractor, Comparator<? super R> comparator, int cResults) Return an aggregator that calculates the top n of the values extracted from a set of entries in a Map.
static <K,V,T,R extends Comparable<? super R>> InvocableMap.StreamingAggregator<K,V,?,R[]>	Aggregators.topN(ValueExtractor<? super T,? extends R> extractor, int cResults) Return an aggregator that calculates the top n of the Comparable values extracted from a set of entries in a Map.

Methods in com.tangosol.util with parameters of type InvocableMap.StreamingAggregator

Modifier and Type	Method and Description
static <K,V,P,R> AsynchronousAggregator<K,V,P,R>	Aggregators.asynchronous(InvocableMap.StreamingAggregator<K,V,P,R> aggregator) Return an AsynchronousAggregator for a given streaming aggregator.
static <K,V,P,R> InvocableMap.EntryAggregator<K,V,R>	Aggregators.asynchronous(InvocableMap.StreamingAggregator<K,V,P,R> aggregator, int iUnitOrderId) Return an AsynchronousAggregator for a given streaming aggregator.

Uses of InvocableMap.StreamingAggregator in com.tangosol.util.aggregator

Classes in com.tangosol.util.aggregator that implement InvocableMap.StreamingAggregator

Modifier and Type	Class and Description
class	AbstractAggregator<K,V,T,E,R> Abstract base class implementation of InvocableMap.EntryAggregator that supports streaming aggregation.
class	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.
class	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.
class	AbstractDoubleAggregator<T> Abstract aggregator that processes numeric values extracted from a set of entries in a Map.
class	AbstractLongAggregator<T> Abstract aggregator that processes numeric values extracted from a set of entries in a Map.
class	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.
class	BigDecimalMax<T> Calculates a maximum of numeric values extracted from a set of entries in a Map in a form of a BigDecimal value.
class	BigDecimalMin<T> Calculates a minimum of numeric values extracted from a set of entries in a Map in a form of a BigDecimal value.
class	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.
class	ComparableMax<T,R> Calculates a maximum among values extracted from a set of entries in a Map.
class	ComparableMin<T,R> Calculates a minimum among values extracted from a set of entries in a Map.
class	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.
static class	CompositeAggregator.Parallel Deprecated. As of Coherence 12.2.1. Use CompositeAggregator instead.
class	Count<K,V> Calculates a number of values in an entry set.
class	DistinctValues<K,V,T,E> Return the set of unique values extracted from a set of entries in a Map.
class	DoubleAverage<T> Calculates an average for values of any numeric type extracted from a set of entries in a Map.
class	DoubleMax<T> Calculates a maximum of numeric values extracted from a set of entries in a Map.
class	DoubleMin<T> Calculates a minimum of numeric values extracted from a set of entries in a Map.
class	DoubleSum<T> Sums up numeric values extracted from a set of entries in a Map.
class	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.
static class	GroupAggregator.Parallel<K,V,T,E,R> Deprecated. As of Coherence 12.2.1. Use GroupAggregator instead.
class	LongMax<T> Calculates a maximum of numeric values extracted from a set of entries in a Map.
class	LongMin<T> Calculates a minimum of numeric values extracted from a set of entries in a Map.
class	LongSum<T> Sums up numeric values extracted from a set of entries in a Map.
class	PriorityAggregator<K,V,P,R> PriorityAggregator is used to explicitly control the scheduling priority and timeouts for execution of EntryAggregator-based methods.
class	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.
class	ReducerAggregator<K,V,T,E> The ReducerAggregator is used to implement functionality similar to CacheMap.getAll(Collection) API.
class	ScriptAggregator<K,V,P,R> ScriptAggregator is a InvocableMap.StreamingAggregator that wraps a script written in one of the languages supported by Graal VM.
class	TopNAggregator<K,V,T,E> TopNAggregator is a ParallelAwareAggregator that aggregates the top N extracted values into an array.

Fields in com.tangosol.util.aggregator declared as InvocableMap.StreamingAggregator

Modifier and Type	Field and Description
protected InvocableMap.StreamingAggregator<K,V,P,R>	AbstractAsynchronousAggregator.m_aggregator The underlying aggregator.

Methods in com.tangosol.util.aggregator that return InvocableMap.StreamingAggregator

Modifier and Type	Method and Description
InvocableMap.StreamingAggregator<K,V,P,R>	PriorityAggregator.getAggregator() Obtain the underlying aggregator.
InvocableMap.StreamingAggregator<K,V,P,R>	AbstractAsynchronousAggregator.getAggregator() Return the underlying streaming aggregator.
protected InvocableMap.StreamingAggregator<? super K,? super V,Object,R>	GroupAggregator.streaming(InvocableMap.EntryAggregator<? super K,? super V,R> aggregator) Convert the specified aggregator to StreamingAggregator.
InvocableMap.StreamingAggregator<K,V,P,R>	ScriptAggregator.supply()
InvocableMap.StreamingAggregator<Object,Object,Object,BigDecimal>	BigDecimalSum.supply()
InvocableMap.StreamingAggregator<Object,Object,Object,Double>	DoubleAverage.supply()
InvocableMap.StreamingAggregator<Object,Object,Object,R>	ComparableMax.supply()
InvocableMap.StreamingAggregator<Object,Object,Object,BigDecimal>	BigDecimalAverage.supply()
InvocableMap.StreamingAggregator<K,V,P,R>	PriorityAggregator.supply()
InvocableMap.StreamingAggregator<K,V,TopNAggregator.PartialResult<E>,E[]>	TopNAggregator.supply()
InvocableMap.StreamingAggregator<K,V,Map<E,Object>,Map<E,R>>	GroupAggregator.supply()
InvocableMap.StreamingAggregator<Object,Object,Object,Long>	LongSum.supply()
InvocableMap.StreamingAggregator<Object,Object,Object,BigDecimal>	BigDecimalMin.supply()
InvocableMap.StreamingAggregator<Object,Object,Object,R>	ComparableMin.supply()
InvocableMap.StreamingAggregator<Object,Object,Object,Double>	DoubleSum.supply()
InvocableMap.StreamingAggregator<K,V,Object,R>	AbstractAggregator.supply()
InvocableMap.StreamingAggregator<K,V,Object,Collection<E>>	DistinctValues.supply()
InvocableMap.StreamingAggregator<Object,Object,Object,BigDecimal>	BigDecimalMax.supply()
InvocableMap.StreamingAggregator<Object,Object,Object,Double>	DoubleMax.supply()
InvocableMap.StreamingAggregator<K,V,Integer,Integer>	Count.supply()
InvocableMap.StreamingAggregator<K,V,Object,List>	CompositeAggregator.supply()
InvocableMap.StreamingAggregator<Object,Object,Object,Long>	LongMax.supply()
InvocableMap.StreamingAggregator<K,V,QueryRecord.PartialResult,QueryRecord>	QueryRecorder.supply()
InvocableMap.StreamingAggregator<K,V,Object,Map<K,E>>	ReducerAggregator.supply()
InvocableMap.StreamingAggregator<Object,Object,Object,Double>	DoubleMin.supply()
InvocableMap.StreamingAggregator<Object,Object,Object,Long>	LongMin.supply()

Constructors in com.tangosol.util.aggregator with parameters of type InvocableMap.StreamingAggregator

Constructor and Description
AbstractAsynchronousAggregator(InvocableMap.StreamingAggregator<K,V,P,R> aggregator, int iUnitOrderId) Construct an AsynchronousAggregator for a given streaming aggregator.
AsynchronousAggregator(InvocableMap.StreamingAggregator<K,V,P,R> aggregator) Construct an AsynchronousAggregator for a given streaming aggregator.
AsynchronousAggregator(InvocableMap.StreamingAggregator<K,V,P,R> aggregator, int iUnitOrderId) Construct an AsynchronousAggregator for a given streaming aggregator.
PriorityAggregator(InvocableMap.StreamingAggregator<K,V,P,R> aggregator) Construct a PriorityAggregator.