io.stargate.db.dse.impl

Class StargateQueryHandler

java.lang.Object

io.stargate.db.dse.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

Field Summary

Fields inherited from interface org.apache.cassandra.cql3.QueryHandler

PROXY_EXECUTE

Constructor Summary

Constructors

Constructor and Description
StargateQueryHandler()

Method Summary

Modifier and Type	Method and Description
Optional<AuthorizationService>	getAuthorizationService()
org.apache.cassandra.cql3.QueryHandler.Prepared	getPrepared(org.apache.cassandra.utils.MD5Digest id)
io.reactivex.Single<org.apache.cassandra.transport.messages.ResultMessage.Prepared>	prepare(String query, org.apache.cassandra.service.QueryState queryState, Map<String,ByteBuffer> customPayload)
io.reactivex.Single<org.apache.cassandra.transport.messages.ResultMessage>	process(String query, org.apache.cassandra.service.QueryState queryState, org.apache.cassandra.cql3.QueryOptions options, Map<String,ByteBuffer> customPayload, long queryStartNanoTime)
io.reactivex.Single<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)
io.reactivex.Single<org.apache.cassandra.transport.messages.ResultMessage>	processStatement(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	register(QueryInterceptor interceptor)
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

register

public void register(QueryInterceptor interceptor)

process

public io.reactivex.Single<org.apache.cassandra.transport.messages.ResultMessage> process(String query,
                                                                                          org.apache.cassandra.service.QueryState queryState,
                                                                                          org.apache.cassandra.cql3.QueryOptions options,
                                                                                          Map<String,ByteBuffer> customPayload,
                                                                                          long queryStartNanoTime)

Specified by:

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

prepare

public io.reactivex.Single<org.apache.cassandra.transport.messages.ResultMessage.Prepared> prepare(String query,
                                                                                                   org.apache.cassandra.service.QueryState queryState,
                                                                                                   Map<String,ByteBuffer> customPayload)

Specified by:

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

getPrepared

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

Specified by:

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

processStatement

public io.reactivex.Single<org.apache.cassandra.transport.messages.ResultMessage> processStatement(org.apache.cassandra.cql3.CQLStatement statement,
                                                                                                   org.apache.cassandra.service.QueryState queryState,
                                                                                                   org.apache.cassandra.cql3.QueryOptions options,
                                                                                                   Map<String,ByteBuffer> customPayload,
                                                                                                   long queryStartNanoTime)

Specified by:

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

processBatch

public io.reactivex.Single<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)

Specified by:

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

setAuthorizationService

public void setAuthorizationService(AtomicReference<AuthorizationService> authorizationService)

getAuthorizationService

public Optional<AuthorizationService> getAuthorizationService()