Package | Description |
---|---|
org.apache.cassandra.cql3 | |
org.apache.cassandra.cql3.statements | |
org.apache.cassandra.transport | |
org.apache.cassandra.transport.messages |
Modifier and Type | Method and Description |
---|---|
ResultMessage |
CQLStatement.execute(QueryState state,
QueryOptions options,
long queryStartNanoTime)
Execute the statement and return the resulting result or null if there is no result.
|
ResultMessage |
CQLStatement.executeInternal(QueryState state,
QueryOptions options)
Variant of execute used for internal query against the system tables, and thus only query the local node.
|
static ResultMessage |
QueryProcessor.process(java.lang.String queryString,
ConsistencyLevel cl,
QueryState queryState,
long queryStartNanoTime) |
ResultMessage |
QueryProcessor.process(java.lang.String queryString,
QueryState queryState,
QueryOptions options,
long queryStartNanoTime) |
ResultMessage |
CustomPayloadMirroringQueryHandler.process(java.lang.String query,
QueryState state,
QueryOptions options,
java.util.Map<java.lang.String,java.nio.ByteBuffer> customPayload,
long queryStartNanoTime) |
ResultMessage |
QueryHandler.process(java.lang.String query,
QueryState state,
QueryOptions options,
java.util.Map<java.lang.String,java.nio.ByteBuffer> customPayload,
long queryStartNanoTime) |
ResultMessage |
QueryProcessor.process(java.lang.String query,
QueryState state,
QueryOptions 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 |
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) |
Modifier and Type | Method and Description |
---|---|
ResultMessage |
AlterRoleStatement.execute(ClientState state) |
abstract ResultMessage |
AuthenticationStatement.execute(ClientState state) |
abstract ResultMessage |
AuthorizationStatement.execute(ClientState state) |
ResultMessage |
CreateRoleStatement.execute(ClientState state) |
ResultMessage |
DropRoleStatement.execute(ClientState state) |
ResultMessage |
GrantPermissionsStatement.execute(ClientState state) |
ResultMessage |
GrantRoleStatement.execute(ClientState state) |
ResultMessage |
ListPermissionsStatement.execute(ClientState state) |
ResultMessage |
ListRolesStatement.execute(ClientState state) |
ResultMessage |
RevokePermissionsStatement.execute(ClientState state) |
ResultMessage |
RevokeRoleStatement.execute(ClientState state) |
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 |
DropIndexStatement.execute(QueryState state,
QueryOptions options,
long queryStartNanoTime) |
ResultMessage |
ModificationStatement.execute(QueryState queryState,
QueryOptions options,
long queryStartNanoTime) |
ResultMessage |
SchemaAlteringStatement.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 |
AuthenticationStatement.executeInternal(QueryState state,
QueryOptions options) |
ResultMessage |
AuthorizationStatement.executeInternal(QueryState state,
QueryOptions options) |
ResultMessage |
BatchStatement.executeInternal(QueryState queryState,
QueryOptions options) |
ResultMessage |
ModificationStatement.executeInternal(QueryState queryState,
QueryOptions options) |
ResultMessage |
SchemaAlteringStatement.executeInternal(QueryState state,
QueryOptions options) |
ResultMessage |
TruncateStatement.executeInternal(QueryState state,
QueryOptions options) |
ResultMessage |
UseStatement.executeInternal(QueryState state,
QueryOptions options) |
ResultMessage |
ModificationStatement.executeInternalWithCondition(QueryState state,
QueryOptions options) |
ResultMessage |
ModificationStatement.executeInternalWithoutCondition(QueryState queryState,
QueryOptions options,
long queryStartNanoTime) |
ResultMessage |
ModificationStatement.executeWithCondition(QueryState queryState,
QueryOptions options,
long queryStartNanoTime) |
protected ResultMessage |
ListRolesStatement.formatResults(java.util.List<RoleResource> sortedRoles) |
protected ResultMessage |
ListUsersStatement.formatResults(java.util.List<RoleResource> sortedRoles) |
Modifier and Type | Method and Description |
---|---|
ResultMessage |
SimpleClient.execute(java.lang.String query,
ConsistencyLevel consistency) |
ResultMessage |
SimpleClient.execute(java.lang.String query,
java.util.List<java.nio.ByteBuffer> values,
ConsistencyLevel consistencyLevel) |
ResultMessage |
SimpleClient.executePrepared(byte[] statementId,
java.util.List<java.nio.ByteBuffer> values,
ConsistencyLevel consistency) |
Modifier and Type | Class and Description |
---|---|
static class |
ResultMessage.Prepared |
static class |
ResultMessage.Rows |
static class |
ResultMessage.SchemaChange |
static class |
ResultMessage.SetKeyspace |
static class |
ResultMessage.Void |
Modifier and Type | Field and Description |
---|---|
static Message.Codec<ResultMessage> |
ResultMessage.codec |
Message.Codec<ResultMessage> |
ResultMessage.Kind.subcodec |
static Message.Codec<ResultMessage> |
ResultMessage.Void.subcodec |
static Message.Codec<ResultMessage> |
ResultMessage.SetKeyspace.subcodec |
static Message.Codec<ResultMessage> |
ResultMessage.Rows.subcodec |
static Message.Codec<ResultMessage> |
ResultMessage.Prepared.subcodec |
static Message.Codec<ResultMessage> |
ResultMessage.SchemaChange.subcodec |
Copyright © 2020 The Apache Software Foundation