Class QueryRecorder
This parallel aggregator used to produce a {@link com.tangosol.util.QueryRecord} object that contains an estimated or actual cost of the query execution for a given filter.
For example, the following code will return a QueryPlan, containing the estimated query cost and corresponding execution steps.
Inherited Members
Namespace: Tangosol.Util.Aggregator
Assembly: Coherence.dll
Syntax
public class QueryRecorder : IParallelAwareAggregator, IEntryAggregator, IPortableObjectConstructors
QueryRecorder()
Default constructor (necessary for IPortableObject interface).
Declaration
public QueryRecorder()QueryRecorder(RecordType)
Construct a QueryRecorder.
Declaration
public QueryRecorder(QueryRecorder.RecordType type)Parameters
| Type | Name | Description |
|---|---|---|
| QueryRecorder.RecordType | type | The type for this aggregator. |
Properties
ParallelAggregator
Get an aggregator that can take the place of this aggregator in situations in which the IInvocableCache can aggregate in parallel.
Declaration
public virtual IEntryAggregator ParallelAggregator { get; }Property Value
| Type | Description |
|---|---|
| IEntryAggregator | The aggregator that will be run in parallel. |
Type
Get the record type for this query recorder.
Declaration
public QueryRecorder.RecordType Type { get; }Property Value
| Type | Description |
|---|---|
| QueryRecorder.RecordType | The record type enum. |
Methods
Aggregate(ICollection)
Process a set of IInvocableCacheEntry objects in order to produce an aggregated result.
Declaration
public virtual object Aggregate(ICollection colEntries)Parameters
| Type | Name | Description |
|---|---|---|
| ICollection | colEntries | A collection of read-only IInvocableCacheEntry objects to aggregate. |
Returns
| Type | Description |
|---|---|
| object | The aggregated result from processing the entries. |
AggregateResults(ICollection)
Aggregate the results of the parallel aggregations.
Declaration
public virtual object AggregateResults(ICollection colResults)Parameters
| Type | Name | Description |
|---|---|---|
| ICollection | colResults | Results to aggregate. |
Returns
| Type | Description |
|---|---|
| object | The aggregation of the parallel aggregation results. |
ReadExternal(IPofReader)
Restore the contents of a user type instance by reading its state using the specified IPofReader object.
Declaration
public virtual void ReadExternal(IPofReader reader)Parameters
| Type | Name | Description |
|---|---|---|
| IPofReader | reader | The IPofReader from which to read the object's state. |
Exceptions
| Type | Condition |
|---|---|
| IOException | If an I/O error occurs. |
WriteExternal(IPofWriter)
Save the contents of a POF user type instance by writing its state using the specified IPofWriter object.
Declaration
public virtual void WriteExternal(IPofWriter writer)Parameters
| Type | Name | Description |
|---|---|---|
| IPofWriter | writer | The IPofWriter to which to write the object's state. |
Exceptions
| Type | Condition |
|---|---|
| IOException | If an I/O error occurs. |