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
InvocableMap.StreamingAggregator<K,V,P,R>	InvocableMap.StreamingAggregator.supply() Create a new instance of this 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 numberic 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	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>	AbstractAsynchronousAggregator.getAggregator() Return the underlying streaming aggregator.
InvocableMap.StreamingAggregator<K,V,P,R>	PriorityAggregator.getAggregator() Obtain the underlying 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,Object,R>	AbstractAggregator.supply()
InvocableMap.StreamingAggregator<Object,Object,Object,BigDecimal>	BigDecimalAverage.supply()
InvocableMap.StreamingAggregator<Object,Object,Object,BigDecimal>	BigDecimalMax.supply()
InvocableMap.StreamingAggregator<Object,Object,Object,BigDecimal>	BigDecimalMin.supply()
InvocableMap.StreamingAggregator<Object,Object,Object,BigDecimal>	BigDecimalSum.supply()
InvocableMap.StreamingAggregator<Object,Object,Object,R>	ComparableMax.supply()
InvocableMap.StreamingAggregator<Object,Object,Object,R>	ComparableMin.supply()
InvocableMap.StreamingAggregator<K,V,Object,List>	CompositeAggregator.supply()
InvocableMap.StreamingAggregator<K,V,Integer,Integer>	Count.supply()
InvocableMap.StreamingAggregator<K,V,Object,Collection<E>>	DistinctValues.supply()
InvocableMap.StreamingAggregator<Object,Object,Object,Double>	DoubleAverage.supply()
InvocableMap.StreamingAggregator<Object,Object,Object,Double>	DoubleMax.supply()
InvocableMap.StreamingAggregator<Object,Object,Object,Double>	DoubleMin.supply()
InvocableMap.StreamingAggregator<Object,Object,Object,Double>	DoubleSum.supply()
InvocableMap.StreamingAggregator<K,V,Map<E,Object>,Map<E,R>>	GroupAggregator.supply()
InvocableMap.StreamingAggregator<Object,Object,Object,Long>	LongMax.supply()
InvocableMap.StreamingAggregator<Object,Object,Object,Long>	LongMin.supply()
InvocableMap.StreamingAggregator<Object,Object,Object,Long>	LongSum.supply()
InvocableMap.StreamingAggregator<K,V,P,R>	PriorityAggregator.supply()
InvocableMap.StreamingAggregator<K,V,QueryRecord.PartialResult,QueryRecord>	QueryRecorder.supply()
InvocableMap.StreamingAggregator<K,V,Object,Map<K,E>>	ReducerAggregator.supply()
InvocableMap.StreamingAggregator<K,V,TopNAggregator.PartialResult<E>,E[]>	TopNAggregator.supply()

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

Constructor and Description
AbstractAsynchronousAggregator(InvocableMap.StreamingAggregator<K,V,P,R> aggregator, boolean fFlowControl, 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 and the automatic flow control "on".
AsynchronousAggregator(InvocableMap.StreamingAggregator<K,V,P,R> aggregator, boolean fFlowControl) Construct an AsynchronousAggregator for a given streaming aggregator.
AsynchronousAggregator(InvocableMap.StreamingAggregator<K,V,P,R> aggregator, boolean fFlowControl, int iUnitOrderId) Construct an AsynchronousAggregator for a given streaming aggregator.
PriorityAggregator(InvocableMap.StreamingAggregator<K,V,P,R> aggregator) Construct a PriorityAggregator.