Uses of Class
org.apache.cassandra.service.QueryState
Packages that use QueryState
Package
Description
-
Uses of QueryState in org.apache.cassandra.audit
Methods in org.apache.cassandra.audit that return QueryStateMethods in org.apache.cassandra.audit with parameters of type QueryStateModifier and TypeMethodDescriptionvoidAuditLogManager.authFailure(QueryState state, Exception cause) voidAuditLogManager.authSuccess(QueryState state) voidAuditLogManager.batchFailure(BatchStatement.Type batchType, List<? extends CQLStatement> statements, List<String> queries, List<List<ByteBuffer>> values, QueryOptions options, QueryState state, Exception cause) voidAuditLogManager.batchSuccess(BatchStatement.Type batchType, List<? extends CQLStatement> statements, List<String> queries, List<List<ByteBuffer>> values, QueryOptions options, QueryState state, long queryTime, Message.Response response) voidAuditLogManager.executeFailure(CQLStatement statement, String query, QueryOptions options, QueryState state, Exception cause) voidAuditLogManager.executeSuccess(CQLStatement statement, String query, QueryOptions options, QueryState state, long queryTime, Message.Response response) voidAuditLogManager.prepareFailure(CQLStatement stmt, String query, QueryState state, Exception cause) voidAuditLogManager.prepareSuccess(CQLStatement statement, String query, QueryState state, long queryTime, ResultMessage.Prepared response) voidAuditLogManager.queryFailure(CQLStatement stmt, String query, QueryOptions options, QueryState state, Exception cause) voidAuditLogManager.querySuccess(CQLStatement statement, String query, QueryOptions options, QueryState state, long queryTime, Message.Response response) AuditLogEntry.Builder.setKeyspace(QueryState queryState, CQLStatement statement) Constructors in org.apache.cassandra.audit with parameters of type QueryState -
Uses of QueryState in org.apache.cassandra.auth
Methods in org.apache.cassandra.auth with parameters of type QueryStateModifier and TypeMethodDescriptionvoidAuthEvents.Listener.authFailure(QueryState state, Exception cause) voidAuthEvents.Listener.authSuccess(QueryState state) voidAuthEvents.notifyAuthFailure(QueryState state, Exception cause) voidAuthEvents.notifyAuthSuccess(QueryState state) -
Uses of QueryState in org.apache.cassandra.cql3
Methods in org.apache.cassandra.cql3 that return QueryStateMethods in org.apache.cassandra.cql3 with parameters of type QueryStateModifier and TypeMethodDescriptiondefault voidQueryEvents.Listener.batchFailure(BatchStatement.Type batchType, List<? extends CQLStatement> statements, List<String> queries, List<List<ByteBuffer>> values, QueryOptions options, QueryState state, Exception cause) default voidQueryEvents.Listener.batchSuccess(BatchStatement.Type batchType, List<? extends CQLStatement> statements, List<String> queries, List<List<ByteBuffer>> values, QueryOptions options, QueryState state, long queryTime, Message.Response response) CQLStatement.execute(QueryState state, QueryOptions options, Dispatcher.RequestTime requestTime) Execute the statement and return the resulting result or null if there is no result.static UntypedResultSetQueryProcessor.execute(String query, ConsistencyLevel cl, QueryState state, Object... values) default voidQueryEvents.Listener.executeFailure(CQLStatement statement, String query, QueryOptions options, QueryState state, Exception cause) 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 voidQueryEvents.Listener.executeSuccess(CQLStatement statement, String query, QueryOptions options, QueryState state, long queryTime, Message.Response response) longBatchQueryOptions.getNowInSeconds(QueryState state) longQueryOptions.getNowInSeconds(QueryState state) longBatchQueryOptions.getTimestamp(QueryState state) longQueryOptions.getTimestamp(QueryState state) voidQueryEvents.notifyBatchFailure(List<QueryHandler.Prepared> prepared, BatchStatement.Type batchType, List<Object> queryOrIdList, List<List<ByteBuffer>> values, QueryOptions options, QueryState state, Exception cause) voidQueryEvents.notifyBatchSuccess(BatchStatement.Type batchType, List<? extends CQLStatement> statements, List<String> queries, List<List<ByteBuffer>> values, QueryOptions options, QueryState state, long queryTime, Message.Response response) voidQueryEvents.notifyExecuteFailure(QueryHandler.Prepared prepared, QueryOptions options, QueryState state, Exception cause) voidQueryEvents.notifyExecuteSuccess(CQLStatement statement, String query, QueryOptions options, QueryState state, long queryTime, Message.Response response) voidQueryEvents.notifyPrepareFailure(CQLStatement statement, String query, QueryState state, Exception cause) voidQueryEvents.notifyPrepareSuccess(Supplier<QueryHandler.Prepared> preparedProvider, String query, QueryState state, long queryTime, ResultMessage.Prepared response) voidQueryEvents.notifyQueryFailure(CQLStatement statement, String query, QueryOptions options, QueryState state, Exception cause) voidQueryEvents.notifyQuerySuccess(CQLStatement statement, String query, QueryOptions options, QueryState state, long queryTime, Message.Response response) CustomPayloadMirroringQueryHandler.parse(String query, QueryState state, QueryOptions options) QueryHandler.parse(String queryString, QueryState queryState, QueryOptions options) QueryProcessor.parse(String queryString, QueryState queryState, QueryOptions options) default voidQueryEvents.Listener.prepareFailure(CQLStatement statement, String query, QueryState state, Exception cause) default voidQueryEvents.Listener.prepareSuccess(CQLStatement statement, String query, QueryState state, long queryTime, ResultMessage.Prepared response) CustomPayloadMirroringQueryHandler.process(CQLStatement statement, QueryState state, QueryOptions options, Map<String, ByteBuffer> customPayload, Dispatcher.RequestTime requestTime) QueryHandler.process(CQLStatement statement, QueryState state, QueryOptions options, Map<String, ByteBuffer> customPayload, Dispatcher.RequestTime requestTime) static ResultMessageQueryProcessor.process(String queryString, ConsistencyLevel cl, QueryState queryState, Dispatcher.RequestTime requestTime) QueryProcessor.process(CQLStatement statement, QueryState state, QueryOptions options, Map<String, ByteBuffer> customPayload, Dispatcher.RequestTime requestTime) QueryProcessor.process(CQLStatement prepared, QueryState queryState, QueryOptions options, Dispatcher.RequestTime requestTime) CustomPayloadMirroringQueryHandler.processBatch(BatchStatement statement, QueryState state, BatchQueryOptions options, Map<String, ByteBuffer> customPayload, Dispatcher.RequestTime requestTime) QueryHandler.processBatch(BatchStatement statement, QueryState state, BatchQueryOptions options, Map<String, ByteBuffer> customPayload, Dispatcher.RequestTime requestTime) QueryProcessor.processBatch(BatchStatement statement, QueryState state, BatchQueryOptions options, Map<String, ByteBuffer> customPayload, Dispatcher.RequestTime requestTime) QueryProcessor.processBatch(BatchStatement batch, QueryState queryState, BatchQueryOptions options, Dispatcher.RequestTime requestTime) CustomPayloadMirroringQueryHandler.processPrepared(CQLStatement statement, QueryState state, QueryOptions options, Map<String, ByteBuffer> customPayload, Dispatcher.RequestTime requestTime) QueryHandler.processPrepared(CQLStatement statement, QueryState state, QueryOptions options, Map<String, ByteBuffer> customPayload, Dispatcher.RequestTime requestTime) QueryProcessor.processPrepared(CQLStatement statement, QueryState state, QueryOptions options, Map<String, ByteBuffer> customPayload, Dispatcher.RequestTime requestTime) QueryProcessor.processPrepared(CQLStatement statement, QueryState queryState, QueryOptions options, Dispatcher.RequestTime requestTime) QueryProcessor.processStatement(CQLStatement statement, QueryState queryState, QueryOptions options, Dispatcher.RequestTime requestTime) default voidQueryEvents.Listener.queryFailure(CQLStatement statement, String query, QueryOptions options, QueryState state, Exception cause) default voidQueryEvents.Listener.querySuccess(CQLStatement statement, 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 QueryStateModifier and TypeMethodDescriptionAuthenticationStatement.execute(QueryState state, QueryOptions options, Dispatcher.RequestTime requestTime) AuthorizationStatement.execute(QueryState state, QueryOptions options, Dispatcher.RequestTime requestTime) BatchStatement.execute(QueryState queryState, BatchQueryOptions options, Dispatcher.RequestTime requestTime) BatchStatement.execute(QueryState queryState, QueryOptions options, Dispatcher.RequestTime requestTime) final ResultMessageDescribeStatement.execute(QueryState state, QueryOptions options, Dispatcher.RequestTime requestTime) ModificationStatement.execute(QueryState queryState, QueryOptions options, Dispatcher.RequestTime requestTime) SelectStatement.execute(QueryState state, QueryOptions options, Dispatcher.RequestTime requestTime) TruncateStatement.execute(QueryState state, QueryOptions options, Dispatcher.RequestTime requestTime) UseStatement.execute(QueryState state, QueryOptions options, Dispatcher.RequestTime requestTime) SelectStatement.executeInternal(QueryState state, QueryOptions options, long nowInSec, Dispatcher.RequestTime requestTime) ModificationStatement.executeInternalWithCondition(QueryState state, QueryOptions options) ModificationStatement.executeInternalWithoutCondition(QueryState queryState, QueryOptions options, Dispatcher.RequestTime requestTime) AuthenticationStatement.executeLocally(QueryState state, QueryOptions options) AuthorizationStatement.executeLocally(QueryState state, QueryOptions options) BatchStatement.executeLocally(QueryState queryState, QueryOptions options) DescribeStatement.executeLocally(QueryState state, QueryOptions options) ModificationStatement.executeLocally(QueryState queryState, QueryOptions options) SelectStatement.executeLocally(QueryState state, QueryOptions options) TruncateStatement.executeLocally(QueryState state, QueryOptions options) UseStatement.executeLocally(QueryState state, QueryOptions options) voidModificationStatement.validateTimestamp(QueryState queryState, QueryOptions options) -
Uses of QueryState in org.apache.cassandra.cql3.statements.schema
Methods in org.apache.cassandra.cql3.statements.schema with parameters of type QueryStateModifier and TypeMethodDescriptionAlterSchemaStatement.execute(QueryState state, boolean locally) AlterSchemaStatement.execute(QueryState state, QueryOptions options, Dispatcher.RequestTime requestTime) AlterSchemaStatement.executeLocally(QueryState state, QueryOptions options) -
Uses of QueryState in org.apache.cassandra.fql
Methods in org.apache.cassandra.fql with parameters of type QueryStateModifier and TypeMethodDescriptionvoidFullQueryLogger.batchSuccess(BatchStatement.Type type, List<? extends CQLStatement> statements, List<String> queries, List<List<ByteBuffer>> values, QueryOptions queryOptions, QueryState queryState, long batchTimeMillis, Message.Response response) Log an invocation of a batch of queriesvoidFullQueryLogger.executeSuccess(CQLStatement statement, String query, QueryOptions options, QueryState state, long queryTime, Message.Response response) voidFullQueryLogger.querySuccess(CQLStatement statement, 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 QueryStateModifierConstructorDescriptionBatch(BatchStatement.Type batchType, List<String> queries, List<List<ByteBuffer>> values, QueryOptions queryOptions, QueryState queryState, long batchTimeMillis) Query(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 -
Uses of QueryState in org.apache.cassandra.transport
Methods in org.apache.cassandra.transport with parameters of type QueryStateModifier and TypeMethodDescriptionfinal Message.ResponseMessage.Request.execute(QueryState queryState, Dispatcher.RequestTime requestTime) protected abstract Message.ResponseMessage.Request.execute(QueryState queryState, Dispatcher.RequestTime requestTime, boolean traceRequest) ServerConnection.getSaslNegotiator(QueryState queryState) -
Uses of QueryState in org.apache.cassandra.transport.messages
Methods in org.apache.cassandra.transport.messages with parameters of type QueryStateModifier and TypeMethodDescriptionprotected Message.ResponseAuthResponse.execute(QueryState queryState, Dispatcher.RequestTime requestTime, boolean traceRequest) protected Message.ResponseBatchMessage.execute(QueryState state, Dispatcher.RequestTime requestTime, boolean traceRequest) protected Message.ResponseExecuteMessage.execute(QueryState state, Dispatcher.RequestTime requestTime, boolean traceRequest) protected Message.ResponseOptionsMessage.execute(QueryState state, Dispatcher.RequestTime requestTime, boolean traceRequest) protected Message.ResponsePrepareMessage.execute(QueryState state, Dispatcher.RequestTime requestTime, boolean traceRequest) protected Message.ResponseQueryMessage.execute(QueryState state, Dispatcher.RequestTime requestTime, boolean traceRequest) protected Message.ResponseRegisterMessage.execute(QueryState state, Dispatcher.RequestTime requestTime, boolean traceRequest) protected Message.ResponseStartupMessage.execute(QueryState state, Dispatcher.RequestTime requestTime, boolean traceRequest)