Package com.tangosol.coherence.dslquery.statement

Class SelectStatementBuilder.AsyncSelectStatement

java.lang.Object

com.tangosol.coherence.dslquery.statement.SelectStatementBuilder.AsyncSelectStatement

Enclosing class:

SelectStatementBuilder

public static class SelectStatementBuilder.AsyncSelectStatement
extends Object

Async implementation of the CohQL "SELECT" command.

Field Summary

Fields

Modifier and Type	Field	Description
protected final InvocableMap.EntryAggregator	f_aggregator	The InvocableMap.EntryAggregator to use in the query.
protected final Filter	f_filter	The Filter to use in the query.
protected final boolean	f_fReduction	Flag to denote whether this query is an aggregation to select specific fields from the values of a cache; e.g. select x, y, z from foo.
protected final String	f_sCache	The name of the cache to query.

Method Summary

Modifier and Type	Method	Description
CompletableFuture<StatementResult>	execute(ExecutionContext ctx)
InvocableMap.EntryAggregator	getAggregator()	Return the InvocableMap.EntryAggregator to use to execute this query.
Filter	getFilter()	Return the Filter to use to execute this query.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

f_sCache

protected final String f_sCache

The name of the cache to query.

f_filter

protected final Filter f_filter

The Filter to use in the query.

f_aggregator

protected final InvocableMap.EntryAggregator f_aggregator

The InvocableMap.EntryAggregator to use in the query.

f_fReduction

protected final boolean f_fReduction

Flag to denote whether this query is an aggregation to select specific fields from the values of a cache; e.g. select x, y, z from foo.

Method Details

execute

public CompletableFuture<StatementResult> execute(ExecutionContext ctx)

getFilter

public Filter getFilter()

Return the Filter to use to execute this query.

Returns:

the Filter to use to execute this query

getAggregator

public InvocableMap.EntryAggregator getAggregator()

Return the InvocableMap.EntryAggregator to use to execute this query.

Returns:

the InvocableMap.EntryAggregator to use to execute this query