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

Packages that use InvocableMap.StreamingAggregator

Package	Description
com.oracle.coherence.ai.search	Contains classes for Coherence AI vector database Knn search functionality.
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.oracle.coherence.ai.search

Classes in com.oracle.coherence.ai.search that implement InvocableMap.StreamingAggregator

Modifier and Type	Class	Description
class	SimilaritySearch<K,V,T>	An InvocableMap.StreamingAggregator to execute a similarity query.

Methods in com.oracle.coherence.ai.search that return InvocableMap.StreamingAggregator

Modifier and Type	Method	Description
InvocableMap.StreamingAggregator<K,V,List<BinaryQueryResult>,List<QueryResult<K,V>>>	SimilaritySearch.supply()

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	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	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	Description
static <K, V, T> InvocableMap.StreamingAggregator<K,V,?,BigDecimal>	Aggregators.average(Remote.ToBigDecimalFunction<? super T> extractor)	Return an aggregator that calculates an average of the BigDecimal values extracted from a set of entries in a Map.
static <K, V, T> InvocableMap.StreamingAggregator<K,V,?,Double>	Aggregators.average(Remote.ToDoubleFunction<? super T> extractor)	Return an aggregator that calculates an average of the double values extracted from a set of entries in a Map.
static <K, V, T> InvocableMap.StreamingAggregator<K,V,?,Double>	Aggregators.average(Remote.ToIntFunction<? super T> extractor)	Return an aggregator that calculates an average of the int values extracted from a set of entries in a Map.
static <K, V, T> InvocableMap.StreamingAggregator<K,V,?,Double>	Aggregators.average(Remote.ToLongFunction<? super T> extractor)	Return an aggregator that calculates an average of the long 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,?,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,?,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.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.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.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.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.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.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> 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, 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, 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.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, 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> 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.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.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.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.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> 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,?,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.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.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.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.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> 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,?,BigDecimal>	Aggregators.max(Remote.ToBigDecimalFunction<? super T> extractor)	Return an aggregator that calculates a maximum of the BigDecimal 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.max(Remote.ToComparableFunction<? 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> InvocableMap.StreamingAggregator<K,V,?,Double>	Aggregators.max(Remote.ToDoubleFunction<? super T> extractor)	Return an aggregator that calculates a maximum of the double values extracted from a set of entries in a Map.
static <K, V, T> InvocableMap.StreamingAggregator<K,V,?,Long>	Aggregators.max(Remote.ToIntFunction<? super T> extractor)	Return an aggregator that calculates a maximum of the int values extracted from a set of entries in a Map.
static <K, V, T> InvocableMap.StreamingAggregator<K,V,?,Long>	Aggregators.max(Remote.ToLongFunction<? super T> extractor)	Return an aggregator that calculates a maximum of the long values extracted from a set of entries in a Map.
static <K, V, T> InvocableMap.StreamingAggregator<K,V,?,BigDecimal>	Aggregators.min(Remote.ToBigDecimalFunction<? super T> extractor)	Return an aggregator that calculates a minimum of the BigDecimal 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.min(Remote.ToComparableFunction<? 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> InvocableMap.StreamingAggregator<K,V,?,Double>	Aggregators.min(Remote.ToDoubleFunction<? super T> extractor)	Return an aggregator that calculates a minimum of the double values extracted from a set of entries in a Map.
static <K, V, T> InvocableMap.StreamingAggregator<K,V,?,Long>	Aggregators.min(Remote.ToIntFunction<? super T> extractor)	Return an aggregator that calculates a minimum of the int values extracted from a set of entries in a Map.
static <K, V, T> InvocableMap.StreamingAggregator<K,V,?,Long>	Aggregators.min(Remote.ToLongFunction<? super T> extractor)	Return an aggregator that calculates a minimum of the long values extracted from a set of entries in a Map.
static <K, V, T> InvocableMap.StreamingAggregator<K,V,?,BigDecimal>	Aggregators.sum(Remote.ToBigDecimalFunction<? super T> extractor)	Return an aggregator that calculates a sum of the BigDecimal values extracted from a set of entries in a Map.
static <K, V, T> InvocableMap.StreamingAggregator<K,V,?,Double>	Aggregators.sum(Remote.ToDoubleFunction<? super T> extractor)	Return an aggregator that calculates a sum of the double values extracted from a set of entries in a Map.
static <K, V, T> InvocableMap.StreamingAggregator<K,V,?,Long>	Aggregators.sum(Remote.ToIntFunction<? super T> extractor)	Return an aggregator that calculates a sum of the int values extracted from a set of entries in a Map.
static <K, V, T> InvocableMap.StreamingAggregator<K,V,?,Long>	Aggregators.sum(Remote.ToLongFunction<? super T> extractor)	Return an aggregator that calculates a sum of the long values extracted from a set of entries in a Map.
InvocableMap.StreamingAggregator<K,V,P,R>	InvocableMap.StreamingAggregator.supply()	Create a new instance of this aggregator.

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

Modifier and Type	Method	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> AsynchronousAggregator<K,V,P,R>	Aggregators.asynchronous(InvocableMap.StreamingAggregator<K,V,P,R> aggregator, int iUnitOrderId)	Return an AsynchronousAggregator for a given streaming aggregator.
static <K, V, P, R> AsynchronousAggregator<K,V,P,R>	Aggregators.asynchronous(InvocableMap.StreamingAggregator<K,V,P,R> aggregator, int iUnitOrderId, Executor executor)	Return an AsynchronousAggregator for a given streaming aggregator.
static <K, V, P, R> AsynchronousAggregator<K,V,P,R>	Aggregators.asynchronous(InvocableMap.StreamingAggregator<K,V,P,R> aggregator, Executor executor)	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	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.
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.
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	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	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,P,R>	ScriptAggregator.supply()
InvocableMap.StreamingAggregator<K,V,TopNAggregator.PartialResult<E>,E[]>	TopNAggregator.supply()

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

Modifier	Constructor	Description
protected	AbstractAsynchronousAggregator(InvocableMap.StreamingAggregator<K,V,P,R> aggregator, int iUnitOrderId)	Construct an AsynchronousAggregator for a given streaming aggregator.
protected	AbstractAsynchronousAggregator(InvocableMap.StreamingAggregator<K,V,P,R> aggregator, int iUnitOrderId, Executor executor)	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.
	AsynchronousAggregator(InvocableMap.StreamingAggregator<K,V,P,R> aggregator, int iUnitOrderId, Executor executor)	Construct an AsynchronousAggregator for a given streaming aggregator.
	AsynchronousAggregator(InvocableMap.StreamingAggregator<K,V,P,R> aggregator, Executor executor)	Construct an AsynchronousAggregator for a given streaming aggregator.
	PriorityAggregator(InvocableMap.StreamingAggregator<K,V,P,R> aggregator)	Construct a PriorityAggregator.