Package org.apache.cassandra.cql3.statements

Class DescribeStatement<T>

java.lang.Object

org.apache.cassandra.cql3.CQLStatement.Raw

org.apache.cassandra.cql3.statements.DescribeStatement<T>

All Implemented Interfaces:

CQLStatement

Direct Known Subclasses:

DescribeStatement.Element, DescribeStatement.Listing

public abstract class DescribeStatement<T>
extends CQLStatement.Raw
implements CQLStatement

The differents DESCRIBE statements parsed from a CQL statement.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	DescribeStatement.Element	DescribeStatement implementation used for describe queries for a single schema element.
static final class	DescribeStatement.Listing	DescribeStatement implementation used for describe queries that only list elements names.

Nested classes/interfaces inherited from interface org.apache.cassandra.cql3.CQLStatement

CQLStatement.Raw, CQLStatement.SingleKeyspaceCqlStatement

Field Summary

Fields inherited from class org.apache.cassandra.cql3.CQLStatement.Raw

bindVariables

Constructor Summary

Constructors

Constructor	Description
DescribeStatement()

Method Summary

Modifier and Type	Method	Description
static DescribeStatement<SchemaElement>	aggregate(String keyspace, String name)	Creates a DescribeStatement for DESCRIBE FUNCTION.
static DescribeStatement<SchemaElement>	aggregates()	Creates a DescribeStatement for DESCRIBE AGGREGATES.
final void	authorize(ClientState state)	Perform any access verification necessary for the statement.
static DescribeStatement<List<Object>>	cluster()	Creates a DescribeStatement for DESCRIBE CLUSTER.
protected abstract Stream<? extends T>	describe(ClientState state, Keyspaces keyspaces)	Returns the schema elements that must be part of the output.
final ResultMessage	execute(QueryState state, QueryOptions options, Dispatcher.RequestTime requestTime)	Execute the statement and return the resulting result or null if there is no result.
ResultMessage	executeLocally(QueryState state, QueryOptions options)	Variant of execute used for internal query against the system tables, and thus only query the local node.
static DescribeStatement<SchemaElement>	function(String keyspace, String name)	Creates a DescribeStatement for DESCRIBE FUNCTION.
static DescribeStatement<SchemaElement>	functions()	Creates a DescribeStatement for DESCRIBE FUNCTIONS.
static DescribeStatement<SchemaElement>	generic(String keyspace, String name)	Creates a DescribeStatement for the generic DESCRIBE ....
final AuditLogContext	getAuditLogContext()	Provides the context needed for audit logging statements.
final List<ColumnSpecification>	getBindVariables()	Returns all bind variables for the statement
static DescribeStatement<SchemaElement>	index(String keyspace, String name)	Creates a DescribeStatement for DESCRIBE INDEX.
static DescribeStatement<SchemaElement>	keyspace(String keyspace, boolean onlyKeyspaceDefinition)	Creates a DescribeStatement for DESCRIBE KEYSPACE.
static DescribeStatement<SchemaElement>	keyspaces()	Creates a DescribeStatement for DESCRIBE KEYSPACES.
protected abstract List<ColumnSpecification>	metadata(ClientState state)	Returns the columns of the ResultMetadata
final CQLStatement	prepare(ClientState clientState)
static DescribeStatement<SchemaElement>	schema(boolean includeSystemKeyspaces)	Creates a DescribeStatement for DESCRIBE [FULL] SCHEMA.
static DescribeStatement<SchemaElement>	table(String keyspace, String name)	Creates a DescribeStatement for DESCRIBE TABLE.
static DescribeStatement<SchemaElement>	tables()	Creates a DescribeStatement for DESCRIBE TABLES.
protected abstract List<ByteBuffer>	toRow(T element, boolean withInternals)
static DescribeStatement<SchemaElement>	type(String keyspace, String name)	Creates a DescribeStatement for DESCRIBE TYPE.
static DescribeStatement<SchemaElement>	types()	Creates a DescribeStatement for DESCRIBE TYPES.
final void	validate(ClientState state)	Perform additional validation required by the statment.
static DescribeStatement<SchemaElement>	view(String keyspace, String name)	Creates a DescribeStatement for DESCRIBE MATERIALIZED VIEW.
final void	withInternalDetails()

Methods inherited from class org.apache.cassandra.cql3.CQLStatement.Raw

setBindVariables

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.cassandra.cql3.CQLStatement

getFunctions, getPartitionKeyBindVariableIndexes, hasConditions

Constructor Details

DescribeStatement

public DescribeStatement()

Method Details

withInternalDetails

public final void withInternalDetails()

prepare

public final CQLStatement prepare(ClientState clientState)
                           throws RequestValidationException

Specified by:

prepare in class CQLStatement.Raw

Throws:

RequestValidationException

getBindVariables

public final List<ColumnSpecification> getBindVariables()

Description copied from interface: CQLStatement

Returns all bind variables for the statement

Specified by:

getBindVariables in interface CQLStatement

authorize

public final void authorize(ClientState state)

Description copied from interface: CQLStatement

Perform any access verification necessary for the statement.

Specified by:

authorize in interface CQLStatement

Parameters:

state - the current client state

validate

public final void validate(ClientState state)

Description copied from interface: CQLStatement

Perform additional validation required by the statment. To be overriden by subclasses if needed.

Specified by:

validate in interface CQLStatement

Parameters:

state - the current client state

getAuditLogContext

public final AuditLogContext getAuditLogContext()

Description copied from interface: CQLStatement

Provides the context needed for audit logging statements.

Specified by:

getAuditLogContext in interface CQLStatement

execute

public final ResultMessage execute(QueryState state,
 QueryOptions options,
 Dispatcher.RequestTime requestTime)
                            throws RequestValidationException,
RequestExecutionException

Description copied from interface: CQLStatement

Execute the statement and return the resulting result or null if there is no result.

Specified by:

execute in interface CQLStatement

Parameters:

state - the current query state

options - options for this query (consistency, variables, pageSize, ...)

requestTime - request enqueue / and start times;

Throws:

RequestValidationException

RequestExecutionException

executeLocally

public ResultMessage executeLocally(QueryState state,
 QueryOptions options)

Description copied from interface: CQLStatement

Variant of execute used for internal query against the system tables, and thus only query the local node.

Specified by:

executeLocally in interface CQLStatement

Parameters:

state - the current query state

metadata

protected abstract List<ColumnSpecification> metadata(ClientState state)

Returns the columns of the ResultMetadata

toRow

protected abstract List<ByteBuffer> toRow(T element,
 boolean withInternals)

describe

protected abstract Stream<? extends T> describe(ClientState state,
 Keyspaces keyspaces)

Returns the schema elements that must be part of the output.

tables

public static DescribeStatement<SchemaElement> tables()

Creates a DescribeStatement for DESCRIBE TABLES.

types

public static DescribeStatement<SchemaElement> types()

Creates a DescribeStatement for DESCRIBE TYPES.

functions

public static DescribeStatement<SchemaElement> functions()

Creates a DescribeStatement for DESCRIBE FUNCTIONS.

aggregates

public static DescribeStatement<SchemaElement> aggregates()

Creates a DescribeStatement for DESCRIBE AGGREGATES.

keyspaces

public static DescribeStatement<SchemaElement> keyspaces()

Creates a DescribeStatement for DESCRIBE KEYSPACES.

schema

public static DescribeStatement<SchemaElement> schema(boolean includeSystemKeyspaces)

Creates a DescribeStatement for DESCRIBE [FULL] SCHEMA.

keyspace

public static DescribeStatement<SchemaElement> keyspace(String keyspace,
 boolean onlyKeyspaceDefinition)

Creates a DescribeStatement for DESCRIBE KEYSPACE.

table

public static DescribeStatement<SchemaElement> table(String keyspace,
 String name)

Creates a DescribeStatement for DESCRIBE TABLE.

index

public static DescribeStatement<SchemaElement> index(String keyspace,
 String name)

Creates a DescribeStatement for DESCRIBE INDEX.

view

public static DescribeStatement<SchemaElement> view(String keyspace,
 String name)

Creates a DescribeStatement for DESCRIBE MATERIALIZED VIEW.

type

public static DescribeStatement<SchemaElement> type(String keyspace,
 String name)

Creates a DescribeStatement for DESCRIBE TYPE.

function

public static DescribeStatement<SchemaElement> function(String keyspace,
 String name)

Creates a DescribeStatement for DESCRIBE FUNCTION.

aggregate

public static DescribeStatement<SchemaElement> aggregate(String keyspace,
 String name)

Creates a DescribeStatement for DESCRIBE FUNCTION.

generic

public static DescribeStatement<SchemaElement> generic(String keyspace,
 String name)

Creates a DescribeStatement for the generic DESCRIBE ....

cluster

public static DescribeStatement<List<Object>> cluster()

Creates a DescribeStatement for DESCRIBE CLUSTER.