Modifier and Type | Method and Description |
---|---|
QueryState |
AuditLogEntry.getState() |
Modifier and Type | Method and 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) |
Constructor and Description |
---|
Builder(QueryState queryState) |
Modifier and Type | Method and 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) |
Modifier and Type | Method and Description |
---|---|
static QueryState |
QueryProcessor.internalQueryState() |
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) |
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 |
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) |
static ResultMessage |
QueryProcessor.process(java.lang.String queryString,
ConsistencyLevel cl,
QueryState queryState,
long queryStartNanoTime) |
ResultMessage |
QueryProcessor.processBatch(BatchStatement batch,
QueryState queryState,
BatchQueryOptions options,
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 statement,
QueryState state,
BatchQueryOptions 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 |
---|---|
ResultMessage |
BatchStatement.execute(QueryState queryState,
BatchQueryOptions options,
long queryStartNanoTime) |
ResultMessage |
AuthenticationStatement.execute(QueryState state,
QueryOptions options,
long queryStartNanoTime) |
ResultMessage |
AuthorizationStatement.execute(QueryState state,
QueryOptions 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) |
Modifier and Type | Method and Description |
---|---|
ResultMessage |
AlterSchemaStatement.execute(QueryState state,
boolean locally) |
ResultMessage |
AlterSchemaStatement.execute(QueryState state,
QueryOptions options,
long queryStartNanoTime) |
ResultMessage |
AlterSchemaStatement.executeLocally(QueryState state,
QueryOptions options) |
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
|
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
|
Constructor and 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) |
Modifier and Type | Method and Description |
---|---|
static QueryState |
QueryState.forInternalCalls() |
Modifier and Type | Method and 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) |
Modifier and Type | Method and 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) |
Copyright © 2009-2022 The Apache Software Foundation