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

Packages that use InvocableMap.EntryAggregator

Package	Description
com.tangosol.coherence.dslquery.internal
com.tangosol.coherence.dslquery.statement	This package contains StatementBuilder implementations and com.tangosol.coherence.dslquery.CohQLStatement implementations.
com.tangosol.coherence.jcache.partitionedcache	Contains classes related to partitioned cache implementation of Coherence JCache.
com.tangosol.coherence.rest.util.aggregator	Contains classes related to REST-based aggregation.
com.tangosol.net	Contains basic cluster interfaces and factories.
com.tangosol.net.cache	Contains classes providing various caching strategies.
com.tangosol.util	Contains various generic utilities.
com.tangosol.util.aggregator	Contains concrete InvocableMap.EntryAggregator implementations.

Uses of InvocableMap.EntryAggregator in com.tangosol.coherence.dslquery.internal

Methods in com.tangosol.coherence.dslquery.internal that return InvocableMap.EntryAggregator

Modifier and Type	Method and Description
InvocableMap.EntryAggregator	SelectListMaker.getResultsAsEntryAggregator() Turn the results of tree processing into an InvocableMap.EntryAggregator that will perform the aggregation.
InvocableMap.EntryAggregator	SelectListMaker.getResultsAsReduction() Turn the results of tree processing into an InvocableMap.EntryAggregator that will return the results of a query.

Uses of InvocableMap.EntryAggregator in com.tangosol.coherence.dslquery.statement

Fields in com.tangosol.coherence.dslquery.statement declared as InvocableMap.EntryAggregator

Modifier and Type	Field and Description
protected InvocableMap.EntryAggregator	SelectStatementBuilder.SelectStatement.f_aggregator The InvocableMap.EntryAggregator to use in the query.

Methods in com.tangosol.coherence.dslquery.statement that return InvocableMap.EntryAggregator

Modifier and Type	Method and Description
protected InvocableMap.EntryAggregator	SelectStatementBuilder.createAggregator(String cacheName, NodeTerm fields, String alias, boolean fDistinct, SelectListMaker transformer) Create the InvocableMap.EntryAggregator that will aggregate the results of this select query.
InvocableMap.EntryAggregator	SelectStatementBuilder.SelectStatement.getAggregator() Return the InvocableMap.EntryAggregator to use to execute this query.

Constructors in com.tangosol.coherence.dslquery.statement with parameters of type InvocableMap.EntryAggregator

Constructor and Description
SelectStatement(String sCache, Filter filter, InvocableMap.EntryAggregator aggregator, boolean fReduction) Construct a SelectStatement that will query the specified cache.

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

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

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.

Uses of InvocableMap.EntryAggregator in com.tangosol.coherence.rest.util.aggregator

Methods in com.tangosol.coherence.rest.util.aggregator that return InvocableMap.EntryAggregator

Modifier and Type	Method and Description
protected InvocableMap.EntryAggregator	DefaultAggregatorFactory.createAggregator(ValueExtractor extractor) Create and initialize a new aggregator instance.
InvocableMap.EntryAggregator<K,V,R>	AggregatorFactory.getAggregator(String... asArgs) Returns an aggregator instance.
InvocableMap.EntryAggregator	DefaultAggregatorFactory.getAggregator(String... asArgs) Return an aggregator instantiated by calling an aggregator class constructor.
InvocableMap.EntryAggregator	AggregatorRegistry.getAggregator(String sRequest) Returns a configured aggregator.

Uses of InvocableMap.EntryAggregator in com.tangosol.net

Methods in com.tangosol.net with parameters of type InvocableMap.EntryAggregator

Modifier and Type	Method and Description
<R> CompletableFuture<R>	AsyncNamedCache.aggregate(Collection<? extends K> collKeys, InvocableMap.EntryAggregator<? super K,? super V,R> aggregator) Perform an aggregating operation asynchronously against the entries specified by the passed keys.
<R> CompletableFuture<R>	AsyncNamedCache.aggregate(Filter filter, InvocableMap.EntryAggregator<? super K,? super V,R> aggregator) Perform an aggregating operation asynchronously against the set of entries that are selected by the given Filter.
default <R> CompletableFuture<R>	AsyncNamedCache.aggregate(InvocableMap.EntryAggregator<? super K,? super V,R> aggregator) Perform an aggregating operation asynchronously against all the entries.

Uses of InvocableMap.EntryAggregator in com.tangosol.net.cache

Methods in com.tangosol.net.cache with parameters of type InvocableMap.EntryAggregator

Modifier and Type	Method and Description
<R> R	ContinuousQueryCache.aggregate(Collection<? extends K> collKeys, InvocableMap.EntryAggregator<? super K,? super V_FRONT,R> aggregator)
<R> R	WrapperNamedCache.aggregate(Collection<? extends K> collKeys, InvocableMap.EntryAggregator<? super K,? super V,R> agent) Perform an aggregating operation against the entries specified by the passed keys.
<R> R	NearCache.aggregate(Collection<? extends K> collKeys, InvocableMap.EntryAggregator<? super K,? super V,R> aggregator) Perform an aggregating operation against the entries specified by the passed keys.
<R> R	ContinuousQueryCache.aggregate(Filter filter, InvocableMap.EntryAggregator<? super K,? super V_FRONT,R> aggregator)
<R> R	WrapperNamedCache.aggregate(Filter filter, InvocableMap.EntryAggregator<? super K,? super V,R> agent) Perform an aggregating operation against the set of entries that are selected by the given Filter.
<R> R	NearCache.aggregate(Filter filter, InvocableMap.EntryAggregator<? super K,? super V,R> aggregator) Perform an aggregating operation against the set of entries that are selected by the given Filter.

Uses of InvocableMap.EntryAggregator in com.tangosol.util

Subinterfaces of InvocableMap.EntryAggregator in com.tangosol.util

Modifier and Type	Interface and Description
static interface	InvocableMap.ParallelAwareAggregator<K,V,P,R> Deprecated. This interface was deprecated in Coherence 12.2.1 and might be removed in a future release. Use InvocableMap.StreamingAggregator instead.
static interface	InvocableMap.StreamingAggregator<K,V,P,R> A StreamingAggregator is an extension of InvocableMap.EntryAggregator that processes entries in a streaming fashion and provides better control over execution characteristics.

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

Modifier and Type	Method and Description
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.
InvocableMap.EntryAggregator<K,V,P>	InvocableMap.ParallelAwareAggregator.getParallelAggregator() Deprecated. Get an aggregator that can take the place of this aggregator in situations in which the InvocableMap can aggregate in parallel.

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

Modifier and Type	Method and Description
<R> R	InvocableMap.aggregate(Collection<? extends K> collKeys, InvocableMap.EntryAggregator<? super K,? super V,R> aggregator) Perform an aggregating operation against the entries specified by the passed keys.
<R> R	ConverterCollections.ConverterInvocableMap.aggregate(Collection<? extends TK> collKeys, InvocableMap.EntryAggregator<? super TK,? super TV,R> agent) Perform an aggregating operation against the entries specified by the passed keys.
<R> R	ConverterCollections.ConverterNamedCache.aggregate(Collection<? extends TK> collKeys, InvocableMap.EntryAggregator<? super TK,? super TV,R> agent) Perform an aggregating operation against the entries specified by the passed keys.
<R> R	InvocableMap.aggregate(Filter filter, InvocableMap.EntryAggregator<? super K,? super V,R> aggregator) Perform an aggregating operation against the set of entries that are selected by the given Filter.
<R> R	ConverterCollections.ConverterInvocableMap.aggregate(Filter filter, InvocableMap.EntryAggregator<? super TK,? super TV,R> agent) Perform an aggregating operation against the set of entries that are selected by the given Filter.
<R> R	ConverterCollections.ConverterNamedCache.aggregate(Filter filter, InvocableMap.EntryAggregator<? super TK,? super TV,R> agent) Perform an aggregating operation against the set of entries that are selected by the given Filter.
default <R> R	InvocableMap.aggregate(InvocableMap.EntryAggregator<? super K,? super V,R> aggregator) Perform an aggregating operation against all the entries.
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,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.

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

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

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	AbstractAsynchronousAggregator<K,V,P,R> Abstract base class for asynchronous entry aggregators.
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	AsynchronousAggregator<K,V,P,R> A marker EntryAggregator wrapper class that allows for an asynchronous invocation of the underlying aggregator.
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.EntryAggregator

Modifier and Type	Field and Description
protected InvocableMap.EntryAggregator[]	CompositeAggregator.m_aAggregator The underlying EntryAggregator array.
protected InvocableMap.EntryAggregator<? super K,? super V,R>	GroupAggregator.m_aggregator The underlying EntryAggregator.

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

Modifier and Type	Method and Description
InvocableMap.EntryAggregator<? super K,? super V,R>	GroupAggregator.getAggregator() Obtain the underlying EntryAggregator.
InvocableMap.EntryAggregator[]	CompositeAggregator.getAggregators() Obtain the EntryAggregator array.

Methods in com.tangosol.util.aggregator with parameters of type InvocableMap.EntryAggregator

Modifier and Type	Method and Description
static CompositeAggregator	CompositeAggregator.createInstance(InvocableMap.EntryAggregator[] aAggregator) Create an instance of CompositeAggregator based on a specified EntryAggregator array.
static <K,V,R> GroupAggregator<K,V,Object,Object,R>	GroupAggregator.createInstance(String sMethod, InvocableMap.EntryAggregator<K,V,R> aggregator) Create an instance of GroupAggregator based on a specified method name(s) and an EntryAggregator.
static <K,V,R> GroupAggregator<K,V,Object,Object,R>	GroupAggregator.createInstance(String sMethod, InvocableMap.EntryAggregator<K,V,R> aggregator, Filter filter) Create an instance of GroupAggregator based on a specified method name(s), an EntryAggregator and a result evaluation filter.
static <K,V,T,E,R> GroupAggregator<K,V,T,E,R>	GroupAggregator.createInstance(ValueExtractor<? super T,? extends E> extractor, InvocableMap.EntryAggregator<? super K,? super V,R> aggregator, Filter filter) Create an instance of GroupAggregator based on a specified extractor and an EntryAggregator and a result evaluation filter.
static <K,V,T,E,R> GroupAggregator<K,V,T,E,R>	GroupAggregator.createInstance(ValueExtractor<? super T,? extends E> extractor, InvocableMap.EntryAggregator<K,V,R> aggregator) Create an instance of GroupAggregator based on a specified extractor and an EntryAggregator.
protected InvocableMap.ParallelAwareAggregator<? super K,? super V,Object,R>	GroupAggregator.parallel(InvocableMap.EntryAggregator<? super K,? super V,R> aggregator) Convert the specified aggregator to ParallelAwareAggregator.
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.

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

Constructor and Description
CompositeAggregator(InvocableMap.EntryAggregator[] aAggregator) Construct a CompositeAggregator based on a specified EntryAggregator array.
GroupAggregator(ValueExtractor<? super T,? extends E> extractor, InvocableMap.EntryAggregator<? super K,? super V,R> aggregator, Filter filter) Construct a GroupAggregator based on a specified ValueExtractor and underlying EntryAggregator.
Parallel(InvocableMap.EntryAggregator[] aAggregator) Deprecated. Construct a CompositeParallelAggregator based on a specified EntryAggregator array.
Parallel(ValueExtractor<? super T,? extends E> extractor, InvocableMap.EntryAggregator<? super K,? super V,R> aggregator, Filter<?> filter) Deprecated. Construct a Parallel aggregator based on a specified ValueExtractor and underlying ParallelAwareAggregator.