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. |
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.
|
Modifier and Type | Method and Description |
---|---|
InvocableMap.StreamingAggregator |
PartitionedJCacheStatistics.PartitionedCacheStatisticsAggregator.supply() |
InvocableMap.StreamingAggregator |
PartitionedJCacheStatistics.PartitionedCacheStatisticsClear.supply() |
Modifier and Type | Method and Description |
---|---|
InvocableMap.StreamingAggregator<K,V,P,R> |
InvocableMap.StreamingAggregator.supply()
Create a new instance of this aggregator.
|
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.
|
Modifier and Type | Field and Description |
---|---|
protected InvocableMap.StreamingAggregator<K,V,P,R> |
AbstractAsynchronousAggregator.m_aggregator
The underlying aggregator.
|
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.
|