Package | Description |
---|---|
org.apache.cassandra.audit | |
org.apache.cassandra.cql3 | |
org.apache.cassandra.cql3.statements | |
org.apache.cassandra.cql3.statements.schema | |
org.apache.cassandra.fql |
Modifier and Type | Method and Description |
---|---|
void |
AuditLogManager.executeFailure(CQLStatement statement,
java.lang.String query,
QueryOptions options,
QueryState state,
java.lang.Exception cause) |
void |
AuditLogManager.executeSuccess(CQLStatement statement,
java.lang.String query,
QueryOptions options,
QueryState state,
long queryTime,
Message.Response response) |
void |
AuditLogManager.prepareFailure(CQLStatement stmt,
java.lang.String query,
QueryState state,
java.lang.Exception cause) |
void |
AuditLogManager.prepareSuccess(CQLStatement statement,
java.lang.String query,
QueryState state,
long queryTime,
ResultMessage.Prepared response) |
void |
AuditLogManager.queryFailure(CQLStatement stmt,
java.lang.String query,
QueryOptions options,
QueryState state,
java.lang.Exception cause) |
void |
AuditLogManager.querySuccess(CQLStatement statement,
java.lang.String query,
QueryOptions options,
QueryState state,
long queryTime,
Message.Response response) |
AuditLogEntry.Builder |
AuditLogEntry.Builder.setKeyspace(CQLStatement statement) |
AuditLogEntry.Builder |
AuditLogEntry.Builder.setKeyspace(QueryState queryState,
CQLStatement statement) |
AuditLogEntry.Builder |
AuditLogEntry.Builder.setScope(CQLStatement statement) |
Modifier and Type | Method and Description |
---|---|
void |
AuditLogManager.batchFailure(BatchStatement.Type batchType,
java.util.List<? extends CQLStatement> statements,
java.util.List<java.lang.String> queries,
java.util.List<java.util.List<java.nio.ByteBuffer>> values,
QueryOptions options,
QueryState state,
java.lang.Exception cause) |
void |
AuditLogManager.batchSuccess(BatchStatement.Type batchType,
java.util.List<? extends CQLStatement> statements,
java.util.List<java.lang.String> queries,
java.util.List<java.util.List<java.nio.ByteBuffer>> values,
QueryOptions options,
QueryState state,
long queryTime,
Message.Response response) |
Modifier and Type | Interface and Description |
---|---|
static interface |
CQLStatement.SingleKeyspaceCqlStatement |
Modifier and Type | Field and Description |
---|---|
CQLStatement |
QueryHandler.Prepared.statement |
Modifier and Type | Method and Description |
---|---|
static CQLStatement |
QueryProcessor.getStatement(java.lang.String queryStr,
ClientState clientState) |
CQLStatement |
CustomPayloadMirroringQueryHandler.parse(java.lang.String query,
QueryState state,
QueryOptions options) |
CQLStatement |
QueryHandler.parse(java.lang.String queryString,
QueryState queryState,
QueryOptions options) |
CQLStatement |
QueryProcessor.parse(java.lang.String queryString,
QueryState queryState,
QueryOptions options) |
static CQLStatement |
QueryProcessor.parseStatement(java.lang.String queryStr,
ClientState clientState) |
abstract CQLStatement |
CQLStatement.Raw.prepare(ClientState state) |
Modifier and Type | Method and Description |
---|---|
default void |
QueryEvents.Listener.executeFailure(CQLStatement statement,
java.lang.String query,
QueryOptions options,
QueryState state,
java.lang.Exception cause) |
default void |
QueryEvents.Listener.executeSuccess(CQLStatement statement,
java.lang.String query,
QueryOptions options,
QueryState state,
long queryTime,
Message.Response response) |
static ResultSet.ResultMetadata |
ResultSet.ResultMetadata.fromPrepared(CQLStatement statement) |
static ResultSet.PreparedMetadata |
ResultSet.PreparedMetadata.fromPrepared(CQLStatement statement) |
static QueryOptions |
QueryProcessor.makeInternalOptions(CQLStatement prepared,
java.lang.Object[] values) |
void |
QueryEvents.notifyExecuteSuccess(CQLStatement statement,
java.lang.String query,
QueryOptions options,
QueryState state,
long queryTime,
Message.Response response) |
void |
QueryEvents.notifyPrepareFailure(CQLStatement statement,
java.lang.String query,
QueryState state,
java.lang.Exception cause) |
void |
QueryEvents.notifyQueryFailure(CQLStatement statement,
java.lang.String query,
QueryOptions options,
QueryState state,
java.lang.Exception cause) |
void |
QueryEvents.notifyQuerySuccess(CQLStatement statement,
java.lang.String query,
QueryOptions options,
QueryState state,
long queryTime,
Message.Response response) |
default void |
QueryEvents.Listener.prepareFailure(CQLStatement statement,
java.lang.String query,
QueryState state,
java.lang.Exception cause) |
default void |
QueryEvents.Listener.prepareSuccess(CQLStatement statement,
java.lang.String query,
QueryState state,
long queryTime,
ResultMessage.Prepared response) |
ResultMessage |
QueryProcessor.process(CQLStatement prepared,
QueryState queryState,
QueryOptions options,
long queryStartNanoTime) |
ResultMessage |
CustomPayloadMirroringQueryHandler.process(CQLStatement statement,
QueryState state,
QueryOptions options,
java.util.Map<java.lang.String,java.nio.ByteBuffer> customPayload,
long queryStartNanoTime) |
ResultMessage |
QueryHandler.process(CQLStatement statement,
QueryState state,
QueryOptions options,
java.util.Map<java.lang.String,java.nio.ByteBuffer> customPayload,
long queryStartNanoTime) |
ResultMessage |
QueryProcessor.process(CQLStatement statement,
QueryState state,
QueryOptions options,
java.util.Map<java.lang.String,java.nio.ByteBuffer> customPayload,
long queryStartNanoTime) |
ResultMessage |
QueryProcessor.processPrepared(CQLStatement statement,
QueryState queryState,
QueryOptions options,
long queryStartNanoTime) |
ResultMessage |
CustomPayloadMirroringQueryHandler.processPrepared(CQLStatement statement,
QueryState state,
QueryOptions options,
java.util.Map<java.lang.String,java.nio.ByteBuffer> customPayload,
long queryStartNanoTime) |
ResultMessage |
QueryHandler.processPrepared(CQLStatement statement,
QueryState state,
QueryOptions options,
java.util.Map<java.lang.String,java.nio.ByteBuffer> customPayload,
long queryStartNanoTime) |
ResultMessage |
QueryProcessor.processPrepared(CQLStatement statement,
QueryState state,
QueryOptions options,
java.util.Map<java.lang.String,java.nio.ByteBuffer> customPayload,
long queryStartNanoTime) |
ResultMessage |
QueryProcessor.processStatement(CQLStatement statement,
QueryState queryState,
QueryOptions options,
long queryStartNanoTime) |
default void |
QueryEvents.Listener.queryFailure(CQLStatement statement,
java.lang.String query,
QueryOptions options,
QueryState state,
java.lang.Exception cause) |
default void |
QueryEvents.Listener.querySuccess(CQLStatement statement,
java.lang.String query,
QueryOptions options,
QueryState state,
long queryTime,
Message.Response response) |
Modifier and Type | Method and Description |
---|---|
default void |
QueryEvents.Listener.batchFailure(BatchStatement.Type batchType,
java.util.List<? extends CQLStatement> statements,
java.util.List<java.lang.String> queries,
java.util.List<java.util.List<java.nio.ByteBuffer>> values,
QueryOptions options,
QueryState state,
java.lang.Exception cause) |
default void |
QueryEvents.Listener.batchSuccess(BatchStatement.Type batchType,
java.util.List<? extends CQLStatement> statements,
java.util.List<java.lang.String> queries,
java.util.List<java.util.List<java.nio.ByteBuffer>> values,
QueryOptions options,
QueryState state,
long queryTime,
Message.Response response) |
void |
QueryEvents.notifyBatchSuccess(BatchStatement.Type batchType,
java.util.List<? extends CQLStatement> statements,
java.util.List<java.lang.String> queries,
java.util.List<java.util.List<java.nio.ByteBuffer>> values,
QueryOptions options,
QueryState state,
long queryTime,
Message.Response response) |
Constructor and Description |
---|
Prepared(CQLStatement statement,
java.lang.String rawCQLStatement,
boolean fullyQualified,
java.lang.String keyspace) |
Modifier and Type | Class and Description |
---|---|
class |
AlterRoleStatement |
class |
AuthenticationStatement |
class |
AuthorizationStatement |
class |
BatchStatement
A
BATCH statement parsed from a CQL query. |
class |
CreateRoleStatement |
class |
DeleteStatement
A
DELETE parsed from a CQL query statement. |
class |
DescribeStatement<T>
The differents
DESCRIBE statements parsed from a CQL statement. |
static class |
DescribeStatement.Element
DescribeStatement implementation used for describe queries for a single schema element. |
static class |
DescribeStatement.Listing
DescribeStatement implementation used for describe queries that only list elements names. |
class |
DropRoleStatement |
class |
GrantPermissionsStatement |
class |
GrantRoleStatement |
class |
ListPermissionsStatement |
class |
ListRolesStatement |
class |
ListUsersStatement |
class |
ModificationStatement |
class |
PermissionsManagementStatement |
class |
RevokePermissionsStatement |
class |
RevokeRoleStatement |
class |
RoleManagementStatement |
class |
SelectStatement
Encapsulates a completely parsed SELECT query, including the target
column family, expression, result count, and ordering clause.
|
class |
TruncateStatement |
class |
UpdateStatement
An
UPDATE statement parsed from a CQL query statement. |
class |
UseStatement |
Modifier and Type | Method and Description |
---|---|
CQLStatement |
DescribeStatement.prepare(ClientState clientState) |
Modifier and Type | Class and Description |
---|---|
class |
AlterKeyspaceStatement |
class |
AlterSchemaStatement |
class |
AlterTableStatement |
static class |
AlterTableStatement.AlterColumn
ALTER TABLE ALTER
|
class |
AlterTypeStatement |
class |
AlterViewStatement |
class |
CreateAggregateStatement |
class |
CreateFunctionStatement |
class |
CreateIndexStatement |
class |
CreateKeyspaceStatement |
class |
CreateTableStatement |
class |
CreateTriggerStatement |
class |
CreateTypeStatement |
class |
CreateViewStatement |
class |
DropAggregateStatement |
class |
DropFunctionStatement |
class |
DropIndexStatement |
class |
DropKeyspaceStatement |
class |
DropTableStatement |
class |
DropTriggerStatement |
class |
DropTypeStatement |
class |
DropViewStatement |
Modifier and Type | Method and Description |
---|---|
void |
FullQueryLogger.executeSuccess(CQLStatement statement,
java.lang.String query,
QueryOptions options,
QueryState state,
long queryTime,
Message.Response response) |
void |
FullQueryLogger.querySuccess(CQLStatement statement,
java.lang.String query,
QueryOptions queryOptions,
QueryState queryState,
long queryTimeMillis,
Message.Response response)
Log a single CQL query
|
Modifier and Type | Method and Description |
---|---|
void |
FullQueryLogger.batchSuccess(BatchStatement.Type type,
java.util.List<? extends CQLStatement> statements,
java.util.List<java.lang.String> queries,
java.util.List<java.util.List<java.nio.ByteBuffer>> values,
QueryOptions queryOptions,
QueryState queryState,
long batchTimeMillis,
Message.Response response)
Log an invocation of a batch of queries
|
Copyright © 2009-2022 The Apache Software Foundation