@java.lang.SuppressWarnings({ "unchecked", "rawtypes" })
public class CassandraDatastore
extends org.grails.datastore.mapping.core.AbstractDatastore
A Datastore implementation for Cassandra. Uses Spring Data Cassandra Factory beans to create and initialise the Cassandra driver cluster and session
| Modifiers | Name | Description |
|---|---|---|
static java.lang.String |
CONTACT_POINTS |
|
static java.lang.String |
DEFAULT_KEYSPACE |
|
static org.springframework.data.cassandra.config.SchemaAction |
DEFAULT_SCHEMA_ACTION |
|
static java.lang.String |
KEYSPACE_ACTION |
|
static java.lang.String |
KEYSPACE_CONFIG |
|
static java.lang.String |
KEYSPACE_DURABLE_WRITES |
|
static java.lang.String |
KEYSPACE_NAME |
|
static java.lang.String |
KEYSPACE_NETWORK_TOPOLOGY |
|
static java.lang.String |
KEYSPACE_REPLICATION_FACTOR |
|
static java.lang.String |
KEYSPACE_REPLICATION_STRATEGY |
|
static java.lang.String |
PORT |
|
static java.lang.String |
SCHEMA_ACTION |
|
protected org.springframework.data.cassandra.core.CassandraAdminTemplate |
cassandraAdminTemplate |
|
protected org.springframework.cassandra.config.CassandraCqlClusterFactoryBean |
cassandraCqlClusterFactoryBean |
|
protected GormCassandraSessionFactoryBean |
cassandraSessionFactoryBean |
|
protected org.springframework.data.cassandra.core.CassandraTemplate |
cassandraTemplate |
|
protected groovy.util.ConfigObject |
configuration |
|
protected java.lang.String |
keyspace |
|
protected org.springframework.cassandra.config.KeyspaceActionSpecificationFactoryBean |
keyspaceActionSpecificationFactoryBean |
|
protected com.datastax.driver.core.Cluster |
nativeCluster |
|
protected com.datastax.driver.core.Session |
nativeSession |
|
protected BasicCassandraMappingContext |
springCassandraMappingContext |
|
protected boolean |
stateless |
| Constructor and description |
|---|
CassandraDatastore
() |
CassandraDatastore
(java.util.Map<java.lang.String, java.lang.String> connectionDetails, org.springframework.context.ConfigurableApplicationContext ctx) |
CassandraDatastore
(CassandraMappingContext mappingContext, java.util.Map<java.lang.String, java.lang.String> connectionDetails, org.springframework.context.ConfigurableApplicationContext ctx) |
| Type | Name and description |
|---|---|
void |
afterPropertiesSet() |
protected org.springframework.data.cassandra.mapping.CassandraMappingContext |
cassandraMapping() |
protected com.datastax.driver.core.Cluster |
createCluster() |
protected java.util.Set<org.springframework.cassandra.core.keyspace.KeyspaceActionSpecification<?>> |
createKeyspaceSpecifications() |
protected com.datastax.driver.core.Session |
createNativeSession() |
protected org.grails.datastore.mapping.core.Session |
createSession(java.util.Map<java.lang.String, java.lang.String> connectionDetails) |
protected org.grails.datastore.mapping.core.Session |
createStatelessSession(java.util.Map<java.lang.String, java.lang.String> connectionDetails) |
void |
createTableDefinition(java.lang.Class<?> cls) |
void |
destroy() |
org.springframework.data.cassandra.core.CassandraTemplate |
getCassandraTemplate() |
com.datastax.driver.core.Cluster |
getNativeCluster() |
com.datastax.driver.core.Session |
getNativeSession() |
org.springframework.cassandra.core.WriteOptions |
getWriteOptions(java.lang.Object o) |
protected void |
initializeConverters(org.grails.datastore.mapping.model.MappingContext mappingContext) |
void |
persistentEntityAdded(org.grails.datastore.mapping.model.PersistentEntity entity) |
void |
setCassandraCqlClusterFactoryBean(org.springframework.cassandra.config.CassandraCqlClusterFactoryBean cassandraCqlClusterFactoryBean) |
void |
setCassandraSessionFactoryBean(GormCassandraSessionFactoryBean cassandraSessionFactoryBean) |
void |
setKeyspaceActionSpecificationFactoryBean(org.springframework.cassandra.config.KeyspaceActionSpecificationFactoryBean keyspaceActionSpecificationFactoryBean) |
void |
setWriteOptions(java.lang.Object o, org.springframework.cassandra.core.WriteOptions writeOptions) |
| Methods inherited from class | Name |
|---|---|
class org.grails.datastore.mapping.core.AbstractDatastore |
org.grails.datastore.mapping.core.AbstractDatastore#getMappingContext(), org.grails.datastore.mapping.core.AbstractDatastore#connectStateless(), org.grails.datastore.mapping.core.AbstractDatastore#getCurrentSession(), org.grails.datastore.mapping.core.AbstractDatastore#hasCurrentSession(), org.grails.datastore.mapping.core.AbstractDatastore#retrieveSession(), org.grails.datastore.mapping.core.AbstractDatastore#retrieveSession(java.lang.Class), org.grails.datastore.mapping.core.AbstractDatastore#getApplicationContext(), org.grails.datastore.mapping.core.AbstractDatastore#getApplicationEventPublisher(), org.grails.datastore.mapping.core.AbstractDatastore#getObjectErrors(java.lang.Object), org.grails.datastore.mapping.core.AbstractDatastore#setObjectErrors(java.lang.Object, org.springframework.validation.Errors), org.grails.datastore.mapping.core.AbstractDatastore#setSkipValidation(java.lang.Object, boolean), org.grails.datastore.mapping.core.AbstractDatastore#skipValidation(java.lang.Object), org.grails.datastore.mapping.core.AbstractDatastore#getValidationErrorsMap(), org.grails.datastore.mapping.core.AbstractDatastore#getValidationSkipMap(), org.grails.datastore.mapping.core.AbstractDatastore#isSchemaless(), org.grails.datastore.mapping.core.AbstractDatastore#setApplicationContext(org.springframework.context.ApplicationContext), org.grails.datastore.mapping.core.AbstractDatastore#setConnectionDetails(java.util.Map), org.grails.datastore.mapping.core.AbstractDatastore#destroy(), org.grails.datastore.mapping.core.AbstractDatastore#connect(), org.grails.datastore.mapping.core.AbstractDatastore#connect(java.util.Map), org.grails.datastore.mapping.core.AbstractDatastore#wait(long, int), org.grails.datastore.mapping.core.AbstractDatastore#wait(long), org.grails.datastore.mapping.core.AbstractDatastore#wait(), org.grails.datastore.mapping.core.AbstractDatastore#equals(java.lang.Object), org.grails.datastore.mapping.core.AbstractDatastore#toString(), org.grails.datastore.mapping.core.AbstractDatastore#hashCode(), org.grails.datastore.mapping.core.AbstractDatastore#getClass(), org.grails.datastore.mapping.core.AbstractDatastore#notify(), org.grails.datastore.mapping.core.AbstractDatastore#notifyAll() |
class java.lang.Object |
java.lang.Object#wait(long, int), java.lang.Object#wait(long), java.lang.Object#wait(), java.lang.Object#equals(java.lang.Object), java.lang.Object#toString(), java.lang.Object#hashCode(), java.lang.Object#getClass(), java.lang.Object#notify(), java.lang.Object#notifyAll() |