| 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. |
| 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.
|
| Modifier and Type | Field and Description |
|---|---|
protected InvocableMap.EntryAggregator |
SelectStatementBuilder.SelectStatement.f_aggregator
The
InvocableMap.EntryAggregator to use in the query. |
| 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. |
| Constructor and Description |
|---|
SelectStatement(String sCache, Filter filter, InvocableMap.EntryAggregator aggregator, boolean fReduction)
Construct a SelectStatement that will query the specified cache.
|
| 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 |
|---|---|
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.
|
| 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.
|
| Modifier and Type | Method and Description |
|---|---|
<R> R |
ContinuousQueryCache.aggregate(Collection<? extends K> collKeys, InvocableMap.EntryAggregator<? super K,? super V_FRONT,R> aggregator)
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 |
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 |
ContinuousQueryCache.aggregate(Filter filter, InvocableMap.EntryAggregator<? super K,? super V_FRONT,R> aggregator)
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.
|
<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.
|
| 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. |
| Modifier and Type | Method and Description |
|---|---|
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.
|
| 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.
|
Object |
ConverterCollections.ConverterInvocableMap.aggregate(Collection collKeys, InvocableMap.EntryAggregator agent)
Perform an aggregating operation against the entries specified by the passed keys.
|
Object |
ConverterCollections.ConverterNamedCache.aggregate(Collection collKeys, InvocableMap.EntryAggregator agent)
Perform an aggregating operation against the entries specified by the passed keys.
|
Object |
ConverterCollections.ConverterInvocableMap.aggregate(Filter filter, InvocableMap.EntryAggregator agent)
Perform an aggregating operation against the set of entries that are selected by the given Filter.
|
Object |
ConverterCollections.ConverterNamedCache.aggregate(Filter filter, InvocableMap.EntryAggregator agent)
Perform an aggregating operation against the set of entries that are selected by the given Filter.
|
<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.
|
default <R> R |
InvocableMap.aggregate(InvocableMap.EntryAggregator<? super K,? super V,R> aggregator)
Perform an aggregating operation against all the entries.
|
| 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 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.EntryAggregator[] |
CompositeAggregator.m_aAggregator
The underlying EntryAggregator array.
|
protected InvocableMap.EntryAggregator<? super K,? super V,R> |
GroupAggregator.m_aggregator
The underlying 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.
|
| 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.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.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.
|
| 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.
|