Uses of Class
org.apache.cassandra.service.QueryState
-
-
Uses of QueryState in org.apache.cassandra.audit
Methods in org.apache.cassandra.audit that return QueryState Modifier and Type Method Description QueryState
AuditLogEntry. getState()
Methods in org.apache.cassandra.audit with parameters of type QueryState Modifier and Type Method Description void
AuditLogManager. authFailure(QueryState state, java.lang.Exception cause)
void
AuditLogManager. authSuccess(QueryState state)
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)
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(QueryState queryState, CQLStatement statement)
Constructors in org.apache.cassandra.audit with parameters of type QueryState Constructor Description Builder(QueryState queryState)
-
Uses of QueryState in org.apache.cassandra.auth
Methods in org.apache.cassandra.auth with parameters of type QueryState Modifier and Type Method Description void
AuthEvents.Listener. authFailure(QueryState state, java.lang.Exception cause)
void
AuthEvents.Listener. authSuccess(QueryState state)
void
AuthEvents. notifyAuthFailure(QueryState state, java.lang.Exception cause)
void
AuthEvents. notifyAuthSuccess(QueryState state)
-
Uses of QueryState in org.apache.cassandra.cql3
Methods in org.apache.cassandra.cql3 that return QueryState Modifier and Type Method Description static QueryState
QueryProcessor. internalQueryState()
Methods in org.apache.cassandra.cql3 with parameters of type QueryState Modifier and Type Method 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)
ResultMessage
CQLStatement. execute(QueryState state, QueryOptions options, long queryStartNanoTime)
Execute the statement and return the resulting result or null if there is no result.static UntypedResultSet
QueryProcessor. execute(java.lang.String query, ConsistencyLevel cl, QueryState state, java.lang.Object... values)
default void
QueryEvents.Listener. executeFailure(CQLStatement statement, java.lang.String query, QueryOptions options, QueryState state, java.lang.Exception cause)
ResultMessage
CQLStatement. executeLocally(QueryState state, QueryOptions options)
Variant of execute used for internal query against the system tables, and thus only query the local node.default void
QueryEvents.Listener. executeSuccess(CQLStatement statement, java.lang.String query, QueryOptions options, QueryState state, long queryTime, Message.Response response)
int
BatchQueryOptions. getNowInSeconds(QueryState state)
int
QueryOptions. getNowInSeconds(QueryState state)
long
BatchQueryOptions. getTimestamp(QueryState state)
long
QueryOptions. getTimestamp(QueryState state)
void
QueryEvents. notifyBatchFailure(java.util.List<QueryHandler.Prepared> prepared, BatchStatement.Type batchType, java.util.List<java.lang.Object> queryOrIdList, java.util.List<java.util.List<java.nio.ByteBuffer>> values, QueryOptions options, QueryState state, java.lang.Exception cause)
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)
void
QueryEvents. notifyExecuteFailure(QueryHandler.Prepared prepared, QueryOptions options, QueryState state, java.lang.Exception cause)
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. notifyPrepareSuccess(java.util.function.Supplier<QueryHandler.Prepared> preparedProvider, java.lang.String query, QueryState state, long queryTime, ResultMessage.Prepared response)
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)
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)
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
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)
static ResultMessage
QueryProcessor. process(java.lang.String queryString, ConsistencyLevel cl, QueryState queryState, long queryStartNanoTime)
ResultMessage
QueryProcessor. process(CQLStatement prepared, QueryState queryState, QueryOptions options, long queryStartNanoTime)
ResultMessage
QueryProcessor. process(CQLStatement statement, QueryState state, QueryOptions options, java.util.Map<java.lang.String,java.nio.ByteBuffer> customPayload, long queryStartNanoTime)
ResultMessage
CustomPayloadMirroringQueryHandler. processBatch(BatchStatement statement, QueryState state, BatchQueryOptions options, java.util.Map<java.lang.String,java.nio.ByteBuffer> customPayload, long queryStartNanoTime)
ResultMessage
QueryHandler. processBatch(BatchStatement statement, QueryState state, BatchQueryOptions options, java.util.Map<java.lang.String,java.nio.ByteBuffer> customPayload, long queryStartNanoTime)
ResultMessage
QueryProcessor. processBatch(BatchStatement batch, QueryState queryState, BatchQueryOptions options, long queryStartNanoTime)
ResultMessage
QueryProcessor. processBatch(BatchStatement statement, QueryState state, BatchQueryOptions options, java.util.Map<java.lang.String,java.nio.ByteBuffer> customPayload, 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 queryState, QueryOptions options, 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)
-
Uses of QueryState in org.apache.cassandra.cql3.statements
Methods in org.apache.cassandra.cql3.statements with parameters of type QueryState Modifier and Type Method Description ResultMessage
AuthenticationStatement. execute(QueryState state, QueryOptions options, long queryStartNanoTime)
ResultMessage
AuthorizationStatement. execute(QueryState state, QueryOptions options, long queryStartNanoTime)
ResultMessage
BatchStatement. execute(QueryState queryState, BatchQueryOptions options, long queryStartNanoTime)
ResultMessage
BatchStatement. execute(QueryState queryState, QueryOptions options, long queryStartNanoTime)
ResultMessage
DescribeStatement. execute(QueryState state, QueryOptions options, long queryStartNanoTime)
ResultMessage
ModificationStatement. execute(QueryState queryState, QueryOptions options, long queryStartNanoTime)
ResultMessage.Rows
SelectStatement. execute(QueryState state, QueryOptions options, long queryStartNanoTime)
ResultMessage
TruncateStatement. execute(QueryState state, QueryOptions options, long queryStartNanoTime)
ResultMessage
UseStatement. execute(QueryState state, QueryOptions options, long queryStartNanoTime)
ResultMessage.Rows
SelectStatement. executeInternal(QueryState state, QueryOptions options, int nowInSec, long queryStartNanoTime)
ResultMessage
ModificationStatement. executeInternalWithCondition(QueryState state, QueryOptions options)
ResultMessage
ModificationStatement. executeInternalWithoutCondition(QueryState queryState, QueryOptions options, long queryStartNanoTime)
ResultMessage
AuthenticationStatement. executeLocally(QueryState state, QueryOptions options)
ResultMessage
AuthorizationStatement. executeLocally(QueryState state, QueryOptions options)
ResultMessage
BatchStatement. executeLocally(QueryState queryState, QueryOptions options)
ResultMessage
DescribeStatement. executeLocally(QueryState state, QueryOptions options)
ResultMessage
ModificationStatement. executeLocally(QueryState queryState, QueryOptions options)
ResultMessage.Rows
SelectStatement. executeLocally(QueryState state, QueryOptions options)
ResultMessage
TruncateStatement. executeLocally(QueryState state, QueryOptions options)
ResultMessage
UseStatement. executeLocally(QueryState state, QueryOptions options)
-
Uses of QueryState in org.apache.cassandra.cql3.statements.schema
Methods in org.apache.cassandra.cql3.statements.schema with parameters of type QueryState Modifier and Type Method Description ResultMessage
AlterSchemaStatement. execute(QueryState state, boolean locally)
ResultMessage
AlterSchemaStatement. execute(QueryState state, QueryOptions options, long queryStartNanoTime)
ResultMessage
AlterSchemaStatement. executeLocally(QueryState state, QueryOptions options)
-
Uses of QueryState in org.apache.cassandra.fql
Methods in org.apache.cassandra.fql with parameters of type QueryState Modifier and Type Method 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 queriesvoid
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 queryConstructors in org.apache.cassandra.fql with parameters of type QueryState Constructor Description Batch(BatchStatement.Type batchType, java.util.List<java.lang.String> queries, java.util.List<java.util.List<java.nio.ByteBuffer>> values, QueryOptions queryOptions, QueryState queryState, long batchTimeMillis)
Query(java.lang.String query, QueryOptions queryOptions, QueryState queryState, long queryStartTime)
-
Uses of QueryState in org.apache.cassandra.service
Methods in org.apache.cassandra.service that return QueryState Modifier and Type Method Description static QueryState
QueryState. forInternalCalls()
-
Uses of QueryState in org.apache.cassandra.transport
Methods in org.apache.cassandra.transport with parameters of type QueryState Modifier and Type Method Description Message.Response
Message.Request. execute(QueryState queryState, long queryStartNanoTime)
protected abstract Message.Response
Message.Request. execute(QueryState queryState, long queryStartNanoTime, boolean traceRequest)
IAuthenticator.SaslNegotiator
ServerConnection. getSaslNegotiator(QueryState queryState)
-
Uses of QueryState in org.apache.cassandra.transport.messages
Methods in org.apache.cassandra.transport.messages with parameters of type QueryState Modifier and Type Method Description protected Message.Response
AuthResponse. execute(QueryState queryState, long queryStartNanoTime, boolean traceRequest)
protected Message.Response
BatchMessage. execute(QueryState state, long queryStartNanoTime, boolean traceRequest)
protected Message.Response
ExecuteMessage. execute(QueryState state, long queryStartNanoTime, boolean traceRequest)
protected Message.Response
OptionsMessage. execute(QueryState state, long queryStartNanoTime, boolean traceRequest)
protected Message.Response
PrepareMessage. execute(QueryState state, long queryStartNanoTime, boolean traceRequest)
protected Message.Response
QueryMessage. execute(QueryState state, long queryStartNanoTime, boolean traceRequest)
protected Message.Response
RegisterMessage. execute(QueryState state, long queryStartNanoTime, boolean traceRequest)
protected Message.Response
StartupMessage. execute(QueryState state, long queryStartNanoTime, boolean traceRequest)
-