Package | Description |
---|---|
org.apache.cassandra.cql3 | |
org.apache.cassandra.cql3.statements | |
org.apache.cassandra.service | |
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.
|
static UntypedResultSet |
QueryProcessor.execute(java.lang.String query,
ConsistencyLevel cl,
QueryState state,
java.lang.Object... values) |
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.
|
long |
BatchQueryOptions.getTimestamp(QueryState state) |
long |
QueryOptions.getTimestamp(QueryState state) |
static ParsedStatement.Prepared |
QueryProcessor.parseStatement(java.lang.String queryStr,
QueryState queryState) |
ResultMessage.Prepared |
QueryProcessor.prepare(java.lang.String queryString,
QueryState queryState) |
ResultMessage.Prepared |
CustomPayloadMirroringQueryHandler.prepare(java.lang.String query,
QueryState state,
java.util.Map<java.lang.String,java.nio.ByteBuffer> customPayload) |
ResultMessage.Prepared |
QueryHandler.prepare(java.lang.String query,
QueryState state,
java.util.Map<java.lang.String,java.nio.ByteBuffer> customPayload) |
ResultMessage.Prepared |
QueryProcessor.prepare(java.lang.String query,
QueryState state,
java.util.Map<java.lang.String,java.nio.ByteBuffer> customPayload) |
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 |
---|---|
Event.SchemaChange |
AlterKeyspaceStatement.announceMigration(QueryState queryState,
boolean isLocalOnly) |
Event.SchemaChange |
AlterTableStatement.announceMigration(QueryState queryState,
boolean isLocalOnly) |
Event.SchemaChange |
AlterTypeStatement.announceMigration(QueryState queryState,
boolean isLocalOnly) |
Event.SchemaChange |
AlterViewStatement.announceMigration(QueryState queryState,
boolean isLocalOnly) |
Event.SchemaChange |
CreateAggregateStatement.announceMigration(QueryState queryState,
boolean isLocalOnly) |
Event.SchemaChange |
CreateFunctionStatement.announceMigration(QueryState queryState,
boolean isLocalOnly) |
Event.SchemaChange |
CreateIndexStatement.announceMigration(QueryState queryState,
boolean isLocalOnly) |
Event.SchemaChange |
CreateKeyspaceStatement.announceMigration(QueryState queryState,
boolean isLocalOnly) |
Event.SchemaChange |
CreateTableStatement.announceMigration(QueryState queryState,
boolean isLocalOnly) |
Event.SchemaChange |
CreateTriggerStatement.announceMigration(QueryState queryState,
boolean isLocalOnly) |
Event.SchemaChange |
CreateTypeStatement.announceMigration(QueryState queryState,
boolean isLocalOnly) |
Event.SchemaChange |
CreateViewStatement.announceMigration(QueryState queryState,
boolean isLocalOnly) |
Event.SchemaChange |
DropAggregateStatement.announceMigration(QueryState queryState,
boolean isLocalOnly) |
Event.SchemaChange |
DropFunctionStatement.announceMigration(QueryState queryState,
boolean isLocalOnly) |
Event.SchemaChange |
DropIndexStatement.announceMigration(QueryState queryState,
boolean isLocalOnly) |
Event.SchemaChange |
DropKeyspaceStatement.announceMigration(QueryState queryState,
boolean isLocalOnly) |
Event.SchemaChange |
DropTableStatement.announceMigration(QueryState queryState,
boolean isLocalOnly) |
Event.SchemaChange |
DropTriggerStatement.announceMigration(QueryState queryState,
boolean isLocalOnly) |
Event.SchemaChange |
DropTypeStatement.announceMigration(QueryState queryState,
boolean isLocalOnly) |
Event.SchemaChange |
DropViewStatement.announceMigration(QueryState queryState,
boolean isLocalOnly) |
protected abstract Event.SchemaChange |
SchemaAlteringStatement.announceMigration(QueryState queryState,
boolean isLocalOnly)
Announces the migration to other nodes in the cluster.
|
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.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 |
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.Rows |
SelectStatement.executeInternal(QueryState state,
QueryOptions options) |
ResultMessage |
TruncateStatement.executeInternal(QueryState state,
QueryOptions options) |
ResultMessage |
UseStatement.executeInternal(QueryState state,
QueryOptions options) |
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 |
ModificationStatement.executeWithCondition(QueryState queryState,
QueryOptions options,
long queryStartNanoTime) |
protected void |
CreateAggregateStatement.grantPermissionsToCreator(QueryState state) |
protected void |
CreateFunctionStatement.grantPermissionsToCreator(QueryState state) |
protected void |
CreateKeyspaceStatement.grantPermissionsToCreator(QueryState state) |
protected void |
CreateTableStatement.grantPermissionsToCreator(QueryState state) |
protected void |
SchemaAlteringStatement.grantPermissionsToCreator(QueryState state)
Schema alteration may result in a new database object (keyspace, table, role, function) being created capable of
having permissions GRANTed on it.
|
Modifier and Type | Method and Description |
---|---|
static QueryState |
QueryState.forInternalCalls() |
Modifier and Type | Method and Description |
---|---|
QueryState |
ServerConnection.validateNewMessage(Message.Type type,
ProtocolVersion version,
int streamId) |
Modifier and Type | Method and Description |
---|---|
abstract Message.Response |
Message.Request.execute(QueryState queryState,
long queryStartNanoTime) |
IAuthenticator.SaslNegotiator |
ServerConnection.getSaslNegotiator(QueryState queryState) |
Modifier and Type | Method and Description |
---|---|
Message.Response |
AuthResponse.execute(QueryState queryState,
long queryStartNanoTime) |
Message.Response |
BatchMessage.execute(QueryState state,
long queryStartNanoTime) |
Message.Response |
CredentialsMessage.execute(QueryState state,
long queryStartNanoTime) |
Message.Response |
ExecuteMessage.execute(QueryState state,
long queryStartNanoTime) |
Message.Response |
OptionsMessage.execute(QueryState state,
long queryStartNanoTime) |
Message.Response |
PrepareMessage.execute(QueryState state,
long queryStartNanoTime) |
Message.Response |
QueryMessage.execute(QueryState state,
long queryStartNanoTime) |
Message.Response |
RegisterMessage.execute(QueryState state,
long queryStartNanoTime) |
Message.Response |
StartupMessage.execute(QueryState state,
long queryStartNanoTime) |
Copyright © 2018 The Apache Software Foundation