io.stargate.db.cassandra.impl

Class StargateQueryHandler

java.lang.Object

io.stargate.db.cassandra.impl.StargateQueryHandler

All Implemented Interfaces:

org.apache.cassandra.cql3.QueryHandler

public class StargateQueryHandler
extends Object
implements org.apache.cassandra.cql3.QueryHandler

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.cassandra.cql3.QueryHandler

org.apache.cassandra.cql3.QueryHandler.Prepared

Constructor Summary

Constructors

Constructor and Description
StargateQueryHandler()

Method Summary

Modifier and Type	Method and Description
protected void	authorizeByToken(Map<String,ByteBuffer> customPayload, org.apache.cassandra.cql3.CQLStatement statement)
Optional<AuthorizationService>	getAuthorizationService()
org.apache.cassandra.cql3.QueryHandler.Prepared	getPrepared(org.apache.cassandra.utils.MD5Digest md5Digest)
org.apache.cassandra.cql3.CQLStatement	parse(String s, org.apache.cassandra.service.QueryState queryState, org.apache.cassandra.cql3.QueryOptions queryOptions)
org.apache.cassandra.transport.messages.ResultMessage.Prepared	prepare(String s, org.apache.cassandra.service.ClientState clientState, Map<String,ByteBuffer> map)
org.apache.cassandra.transport.messages.ResultMessage	process(org.apache.cassandra.cql3.CQLStatement statement, org.apache.cassandra.service.QueryState queryState, org.apache.cassandra.cql3.QueryOptions options, Map<String,ByteBuffer> customPayload, long queryStartNanoTime)
org.apache.cassandra.transport.messages.ResultMessage	processBatch(org.apache.cassandra.cql3.statements.BatchStatement batchStatement, org.apache.cassandra.service.QueryState queryState, org.apache.cassandra.cql3.BatchQueryOptions options, Map<String,ByteBuffer> customPayload, long queryStartNanoTime)
org.apache.cassandra.transport.messages.ResultMessage	processPrepared(org.apache.cassandra.cql3.CQLStatement statement, org.apache.cassandra.service.QueryState queryState, org.apache.cassandra.cql3.QueryOptions options, Map<String,ByteBuffer> customPayload, long queryStartNanoTime)
void	setAuthorizationService(AtomicReference<AuthorizationService> authorizationService)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StargateQueryHandler

public StargateQueryHandler()

Method Detail

parse

public org.apache.cassandra.cql3.CQLStatement parse(String s,
                                                    org.apache.cassandra.service.QueryState queryState,
                                                    org.apache.cassandra.cql3.QueryOptions queryOptions)

Specified by:

parse in interface org.apache.cassandra.cql3.QueryHandler

process

public org.apache.cassandra.transport.messages.ResultMessage process(org.apache.cassandra.cql3.CQLStatement statement,
                                                                     org.apache.cassandra.service.QueryState queryState,
                                                                     org.apache.cassandra.cql3.QueryOptions options,
                                                                     Map<String,ByteBuffer> customPayload,
                                                                     long queryStartNanoTime)
                                                              throws org.apache.cassandra.exceptions.RequestExecutionException,
                                                                     org.apache.cassandra.exceptions.RequestValidationException

Specified by:

process in interface org.apache.cassandra.cql3.QueryHandler

Throws:

org.apache.cassandra.exceptions.RequestExecutionException

org.apache.cassandra.exceptions.RequestValidationException

prepare

public org.apache.cassandra.transport.messages.ResultMessage.Prepared prepare(String s,
                                                                              org.apache.cassandra.service.ClientState clientState,
                                                                              Map<String,ByteBuffer> map)
                                                                       throws org.apache.cassandra.exceptions.RequestValidationException

Specified by:

prepare in interface org.apache.cassandra.cql3.QueryHandler

Throws:

org.apache.cassandra.exceptions.RequestValidationException

getPrepared

public org.apache.cassandra.cql3.QueryHandler.Prepared getPrepared(org.apache.cassandra.utils.MD5Digest md5Digest)

Specified by:

getPrepared in interface org.apache.cassandra.cql3.QueryHandler

processPrepared

public org.apache.cassandra.transport.messages.ResultMessage processPrepared(org.apache.cassandra.cql3.CQLStatement statement,
                                                                             org.apache.cassandra.service.QueryState queryState,
                                                                             org.apache.cassandra.cql3.QueryOptions options,
                                                                             Map<String,ByteBuffer> customPayload,
                                                                             long queryStartNanoTime)
                                                                      throws org.apache.cassandra.exceptions.RequestExecutionException,
                                                                             org.apache.cassandra.exceptions.RequestValidationException

Specified by:

processPrepared in interface org.apache.cassandra.cql3.QueryHandler

Throws:

org.apache.cassandra.exceptions.RequestExecutionException

org.apache.cassandra.exceptions.RequestValidationException

processBatch

public org.apache.cassandra.transport.messages.ResultMessage processBatch(org.apache.cassandra.cql3.statements.BatchStatement batchStatement,
                                                                          org.apache.cassandra.service.QueryState queryState,
                                                                          org.apache.cassandra.cql3.BatchQueryOptions options,
                                                                          Map<String,ByteBuffer> customPayload,
                                                                          long queryStartNanoTime)
                                                                   throws org.apache.cassandra.exceptions.RequestExecutionException,
                                                                          org.apache.cassandra.exceptions.RequestValidationException

Specified by:

processBatch in interface org.apache.cassandra.cql3.QueryHandler

Throws:

org.apache.cassandra.exceptions.RequestExecutionException

org.apache.cassandra.exceptions.RequestValidationException

authorizeByToken

protected void authorizeByToken(Map<String,ByteBuffer> customPayload,
                                org.apache.cassandra.cql3.CQLStatement statement)

setAuthorizationService

public void setAuthorizationService(AtomicReference<AuthorizationService> authorizationService)

getAuthorizationService

public Optional<AuthorizationService> getAuthorizationService()