io.stargate.db.dse.impl

Class DsePersistence

java.lang.Object

io.stargate.db.datastore.common.AbstractCassandraPersistence<org.apache.cassandra.config.Config,org.apache.cassandra.schema.KeyspaceMetadata,org.apache.cassandra.schema.TableMetadata,org.apache.cassandra.schema.ColumnMetadata,org.apache.cassandra.db.marshal.UserType,org.apache.cassandra.schema.IndexMetadata,org.apache.cassandra.schema.ViewTableMetadata>

io.stargate.db.dse.impl.DsePersistence

All Implemented Interfaces:

Persistence

public class DsePersistence
extends AbstractCassandraPersistence<org.apache.cassandra.config.Config,org.apache.cassandra.schema.KeyspaceMetadata,org.apache.cassandra.schema.TableMetadata,org.apache.cassandra.schema.ColumnMetadata,org.apache.cassandra.db.marshal.UserType,org.apache.cassandra.schema.IndexMetadata,org.apache.cassandra.schema.ViewTableMetadata>

Nested Class Summary

Nested classes/interfaces inherited from class io.stargate.db.datastore.common.AbstractCassandraPersistence

AbstractCassandraPersistence.AbstractConnection

Nested classes/interfaces inherited from interface io.stargate.db.Persistence

Persistence.Connection

Field Summary

Fields

Modifier and Type	Field and Description
static Boolean	USE_PROXY_PROTOCOL

Fields inherited from interface io.stargate.db.Persistence

SCHEMA_AGREEMENT_WAIT_RETRIES

Constructor Summary

Constructors

Constructor and Description
DsePersistence()

Method Summary

Modifier and Type	Method and Description
Map<String,List<String>>	cqlSupportedOptions()
protected Iterable<org.apache.cassandra.schema.KeyspaceMetadata>	currentInternalSchema()
protected void	destroyPersistence()
Authenticator	getAuthenticator()
protected void	initializePersistence(org.apache.cassandra.config.Config config)
boolean	isInSchemaAgreement()
Persistence.Connection	newConnection()
Persistence.Connection	newConnection(ClientInfo clientInfo)
protected SchemaConverter	newSchemaConverter()
void	registerEventListener(EventListener listener)
protected void	registerInternalSchemaListener(Runnable runOnSchemaChange)
void	setAuthorizationService(AtomicReference<AuthorizationService> authorizationService)
void	setRpcReady(boolean status)
protected void	unregisterInternalSchemaListener()
ByteBuffer	unsetValue()

Methods inherited from class io.stargate.db.datastore.common.AbstractCassandraPersistence

destroy, initialize, name, schema, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.stargate.db.Persistence

supportsSecondaryIndex, waitForSchemaAgreement

Field Detail

USE_PROXY_PROTOCOL

public static final Boolean USE_PROXY_PROTOCOL

Constructor Detail

DsePersistence

public DsePersistence()

Method Detail

newSchemaConverter

protected SchemaConverter newSchemaConverter()

Specified by:

newSchemaConverter in class AbstractCassandraPersistence<org.apache.cassandra.config.Config,org.apache.cassandra.schema.KeyspaceMetadata,org.apache.cassandra.schema.TableMetadata,org.apache.cassandra.schema.ColumnMetadata,org.apache.cassandra.db.marshal.UserType,org.apache.cassandra.schema.IndexMetadata,org.apache.cassandra.schema.ViewTableMetadata>

currentInternalSchema

protected Iterable<org.apache.cassandra.schema.KeyspaceMetadata> currentInternalSchema()

Specified by:

currentInternalSchema in class AbstractCassandraPersistence<org.apache.cassandra.config.Config,org.apache.cassandra.schema.KeyspaceMetadata,org.apache.cassandra.schema.TableMetadata,org.apache.cassandra.schema.ColumnMetadata,org.apache.cassandra.db.marshal.UserType,org.apache.cassandra.schema.IndexMetadata,org.apache.cassandra.schema.ViewTableMetadata>

registerInternalSchemaListener

protected void registerInternalSchemaListener(Runnable runOnSchemaChange)

Specified by:

registerInternalSchemaListener in class AbstractCassandraPersistence<org.apache.cassandra.config.Config,org.apache.cassandra.schema.KeyspaceMetadata,org.apache.cassandra.schema.TableMetadata,org.apache.cassandra.schema.ColumnMetadata,org.apache.cassandra.db.marshal.UserType,org.apache.cassandra.schema.IndexMetadata,org.apache.cassandra.schema.ViewTableMetadata>

unregisterInternalSchemaListener

protected void unregisterInternalSchemaListener()

Specified by:

unregisterInternalSchemaListener in class AbstractCassandraPersistence<org.apache.cassandra.config.Config,org.apache.cassandra.schema.KeyspaceMetadata,org.apache.cassandra.schema.TableMetadata,org.apache.cassandra.schema.ColumnMetadata,org.apache.cassandra.db.marshal.UserType,org.apache.cassandra.schema.IndexMetadata,org.apache.cassandra.schema.ViewTableMetadata>

initializePersistence

protected void initializePersistence(org.apache.cassandra.config.Config config)

Specified by:

initializePersistence in class AbstractCassandraPersistence<org.apache.cassandra.config.Config,org.apache.cassandra.schema.KeyspaceMetadata,org.apache.cassandra.schema.TableMetadata,org.apache.cassandra.schema.ColumnMetadata,org.apache.cassandra.db.marshal.UserType,org.apache.cassandra.schema.IndexMetadata,org.apache.cassandra.schema.ViewTableMetadata>

destroyPersistence

protected void destroyPersistence()

Specified by:

destroyPersistence in class AbstractCassandraPersistence<org.apache.cassandra.config.Config,org.apache.cassandra.schema.KeyspaceMetadata,org.apache.cassandra.schema.TableMetadata,org.apache.cassandra.schema.ColumnMetadata,org.apache.cassandra.db.marshal.UserType,org.apache.cassandra.schema.IndexMetadata,org.apache.cassandra.schema.ViewTableMetadata>

registerEventListener

public void registerEventListener(EventListener listener)

getAuthenticator

public Authenticator getAuthenticator()

setRpcReady

public void setRpcReady(boolean status)

newConnection

public Persistence.Connection newConnection(ClientInfo clientInfo)

newConnection

public Persistence.Connection newConnection()

unsetValue

public ByteBuffer unsetValue()

isInSchemaAgreement

public boolean isInSchemaAgreement()

cqlSupportedOptions

public Map<String,List<String>> cqlSupportedOptions()

setAuthorizationService

public void setAuthorizationService(AtomicReference<AuthorizationService> authorizationService)