Package com.tangosol.coherence.dslquery.statement

Class SelectStatementBuilder.SelectStatement

java.lang.Object

com.tangosol.util.Base

com.tangosol.coherence.dslquery.statement.AbstractStatement

com.tangosol.coherence.dslquery.statement.SelectStatementBuilder.SelectStatement

All Implemented Interfaces:

Statement

Enclosing class:

SelectStatementBuilder

public static class SelectStatementBuilder.SelectStatement
extends AbstractStatement

Implementation of the CohQL "SELECT" command.

Nested Class Summary

Nested classes/interfaces inherited from class com.tangosol.util.Base

Base.LoggingWriter

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.

Fields inherited from class com.tangosol.util.Base

LOG_ALWAYS, LOG_CONFIG, LOG_DEBUG, LOG_ERR, LOG_INFO, LOG_MAX, LOG_MIN, LOG_QUIET, LOG_WARN, POWER_0, POWER_G, POWER_K, POWER_M, POWER_T, UNIT_D, UNIT_H, UNIT_M, UNIT_MS, UNIT_NS, UNIT_S, UNIT_US

Constructor Summary

Constructors

Constructor	Description
SelectStatement(String sCache, Filter filter, InvocableMap.EntryAggregator aggregator, boolean fReduction)	Construct a SelectStatement that will query the specified cache.

Method Summary

Modifier and Type	Method	Description
StatementResult	execute(ExecutionContext ctx)	Execute a CohQL query or command and return the relevant result.
CompletableFuture<StatementResult>	executeAsync(ExecutionContext ctx)	Execute a CohQL query or command asynchronously and return the CompletableFuture with the relevant result.
InvocableMap.EntryAggregator	getAggregator()	Return the InvocableMap.EntryAggregator to use to execute this query.
Filter	getFilter()	Return the Filter to use to execute this query.
void	sanityCheck(ExecutionContext ctx)	Perform sanity checks on the statement that will be executed.
void	showPlan(PrintWriter out)	Output to the provided PrintWriter a human readable trace of the actions that will be taken by this statement if or when executed.

Methods inherited from class com.tangosol.coherence.dslquery.statement.AbstractStatement

assertCacheName, getExecutionConfirmation

Methods inherited from class com.tangosol.util.Base

azzert, azzert, azzert, azzertFailed, breakLines, breakLines, capitalize, checkNotEmpty, checkNotNull, checkRange, computeSafeWaitTime, decimalValue, dup, dup, ensureBigDecimal, ensureClassLoader, ensureRuntimeException, ensureRuntimeException, equals, equalsDeep, err, err, err, err, err, escape, formatDateTime, getCallerStackFrame, getCommonMonitor, getCommonMonitor, getCommonMonitor, getContextClassLoader, getContextClassLoader, getDeepMessage, getErr, getLastSafeTimeMillis, getLog, getMaxDecDigits, getMaxHexDigits, getOriginalException, getOut, getProcessRandom, getRandom, getRandomBinary, getRandomBinary, getRandomString, getSafeTimeMillis, getStackFrame, getStackFrames, getStackTrace, getStackTrace, getStackTrace, getThreadFactory, getTimeZone, getUpTimeMillis, hashCode, hexValue, indentString, indentString, isDecimal, isHex, isLogEcho, isOctal, log, log, log, log, log, makeInteger, makeLong, makeThread, mergeArray, mergeBooleanArray, mergeByteArray, mergeCharArray, mergeDoubleArray, mergeFloatArray, mergeIntArray, mergeLongArray, mod, mod, octalValue, out, out, out, out, out, pad, parseBandwidth, parseBandwidth, parseDelimitedString, parseHex, parseHex, parseMemorySize, parseMemorySize, parsePercentage, parseTime, parseTime, parseTimeNanos, parseTimeNanos, printStackTrace, randomize, randomize, randomize, randomize, read, read, read, read, read, read, read, replace, setErr, setLog, setLogEcho, setOut, sleep, toBandwidthString, toBandwidthString, toCharEscape, toCrc, toCrc, toCrc, toCrc, toCrc, toDecString, toDelimitedString, toDelimitedString, toDelimitedString, toDelimitedString, toHex, toHex, toHexDump, toHexEscape, toHexEscape, toHexEscape, toHexEscape, toHexString, toMemorySizeString, toMemorySizeString, toQuotedCharEscape, toQuotedStringEscape, toSqlString, toString, toString, toStringEscape, toUnicodeEscape, trace, trace, trace, trace, trace, trace, trace, trace, trace, truncateString, truncateString, wait

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.tangosol.coherence.dslquery.Statement

isManagingTimeout

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.

Constructor Details

SelectStatement

public SelectStatement(String sCache,
 Filter filter,
 InvocableMap.EntryAggregator aggregator,
 boolean fReduction)

Construct a SelectStatement that will query the specified cache.

Parameters:

sCache - the cache to query

filter - the Filter to use to query tha cache

aggregator - the InvocableMap.EntryAggregator to run against the cache entries

fReduction - a flag indicating whether this query is a sub-set of entry fields

Method Details

execute

public StatementResult execute(ExecutionContext ctx)

Description copied from interface: Statement

Execute a CohQL query or command and return the relevant result.

Parameters:

ctx - the context to use

Returns:

a StatementResult containing the results of executing the statement

executeAsync

public CompletableFuture<StatementResult> executeAsync(ExecutionContext ctx)

Description copied from interface: Statement

Execute a CohQL query or command asynchronously and return the CompletableFuture with the relevant result.

Parameters:

ctx - the context to use

Returns:

a StatementResult future containing the results of executing the statement

showPlan

public void showPlan(PrintWriter out)

Description copied from interface: Statement

Output to the provided PrintWriter a human readable trace of the actions that will be taken by this statement if or when executed.

Parameters:

out - the PrintWriter to write the trace to

sanityCheck

public void sanityCheck(ExecutionContext ctx)

Description copied from interface: Statement

Perform sanity checks on the statement that will be executed.

Implementations can fail sanity checking by throwing an unchecked exception (RuntimeException).

Specified by:

sanityCheck in interface Statement

Overrides:

sanityCheck in class AbstractStatement

Parameters:

ctx - the context to use

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