io.stargate.db.datastore.common

Class AbstractCassandraPersistence<Config,K,T,C,U,I,V>

java.lang.Object

io.stargate.db.datastore.common.AbstractCassandraPersistence<Config,K,T,C,U,I,V>

Type Parameters:

Config -

K - the concrete class for keyspace metadata in the persistence layer.

T - the concrete class for table metadata in the persistence layer.

C - the concrete class for column metadata in the persistence layer.

U - the concrete class for user types in the persistence layer.

I - the concrete class for secondary indexes metadata in the persistence layer.

V - the concrete class for materialized views metadata in the persistence layer.

All Implemented Interfaces:

Persistence, SchemaAgreementChecker

public abstract class AbstractCassandraPersistence<Config,K,T,C,U,I,V>
extends Object
implements Persistence

A convenience base class aimed at simplifying the writing of a Cassandra-like Persistence layer.

Technically, this is meant to limit as much as reasonable the amount of code duplication between the persistence layers for various C* versions.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	AbstractCassandraPersistence.AbstractConnection

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

Persistence.Connection

Field Summary

Fields inherited from interface io.stargate.db.Persistence

SUPPORTS_SECONDARY_INDEX

Fields inherited from interface io.stargate.db.SchemaAgreementChecker

SCHEMA_AGREEMENT_WAIT_RETRIES

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractCassandraPersistence(String name)

Method Summary

Modifier and Type	Method and Description
protected abstract Iterable<K>	currentInternalSchema() The current schema of the concrete persistence layer.
void	destroy()
protected abstract void	destroyPersistence() Actually destroys the persistence layer (basically, the destroy() implementation, but modulo the parts that are already handled by this abstract facility)
void	initialize(Config config)
protected abstract void	initializePersistence(Config config) Actually initialize the persistence layer (basically, the initialize(Config) implementation, but modulo the parts that are already handled by this abstract facility)
String	name()
protected abstract AbstractCassandraSchemaConverter<K,T,C,U,I,V>	newSchemaConverter() Creates a new, stateless, converter for the schema of the concrete persistence layer.
protected abstract void	registerInternalSchemaListener(Runnable onSchemaChange) Register an internal schema listener that runs the provided runnable every time the internal schema of the persistence layer changes.
Schema	schema()
String	toString()
protected abstract void	unregisterInternalSchemaListener() Unregister the internal schema listener registered through registerInternalSchemaListener(Runnable), if necessary.

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

cqlSupportedOptions, decorateKeyspaceName, executeAuthResponse, getAuthenticator, isInSchemaAgreementWithStorage, isSchemaAgreementAchievable, newConnection, newConnection, registerEventListener, setRpcReady, supportsLoggedBatches, supportsSAI, supportsSecondaryIndex, unsetValue

Methods inherited from interface io.stargate.db.SchemaAgreementChecker

isInSchemaAgreement, waitForSchemaAgreement

Constructor Detail

AbstractCassandraPersistence

protected AbstractCassandraPersistence(String name)

Method Detail

newSchemaConverter

protected abstract AbstractCassandraSchemaConverter<K,T,C,U,I,V> newSchemaConverter()

Creates a new, stateless, converter for the schema of the concrete persistence layer.

currentInternalSchema

protected abstract Iterable<K> currentInternalSchema()

The current schema of the concrete persistence layer.

registerInternalSchemaListener

protected abstract void registerInternalSchemaListener(Runnable onSchemaChange)

Register an internal schema listener that runs the provided runnable every time the internal schema of the persistence layer changes.

This is guaranteed to be called only once for each persistence instance, during initialization. Implementations should usually keep track of the registered listener so they can implement unregisterInternalSchemaListener().

unregisterInternalSchemaListener

protected abstract void unregisterInternalSchemaListener()

Unregister the internal schema listener registered through registerInternalSchemaListener(Runnable), if necessary.

initializePersistence

protected abstract void initializePersistence(Config config)

Actually initialize the persistence layer (basically, the initialize(Config) implementation, but modulo the parts that are already handled by this abstract facility)

destroyPersistence

protected abstract void destroyPersistence()

Actually destroys the persistence layer (basically, the destroy() implementation, but modulo the parts that are already handled by this abstract facility)

name

public final String name()

Specified by:

name in interface Persistence

schema

public final Schema schema()

Specified by:

schema in interface Persistence

initialize

public final void initialize(Config config)

destroy

public final void destroy()

toString

public String toString()

Overrides:

toString in class Object