info.archinnov.achilles.embedded

Class CassandraEmbeddedServer

java.lang.Object

info.archinnov.achilles.embedded.CassandraEmbeddedServer

public class CassandraEmbeddedServer
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static String	CASSANDRA_HOST
static String	FORCE_TABLE_CREATION_FLAG
static org.slf4j.Logger	LOGGER

Constructor Summary

Constructors

Constructor and Description
CassandraEmbeddedServer(info.archinnov.achilles.type.TypedMap originalParameters, ConfigMap achillesParameters) Start a Cassandra embedded server This constructor is not meant to be used directly.

Method Summary

Modifier and Type	Method and Description
AsyncManager	getAsyncManager(String keyspaceName)
com.datastax.driver.core.Cluster	getNativeCluster()
com.datastax.driver.core.Session	getNativeSession(String keyspaceName)
PersistenceManager	getPersistenceManager(String keyspaceName)
PersistenceManagerFactory	getPersistenceManagerFactory(String keyspaceName)
void	truncateTable(String keyspaceName, String tableName)

Methods inherited from class java.lang.Object

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

Field Detail

LOGGER

public static final org.slf4j.Logger LOGGER

CASSANDRA_HOST

public static final String CASSANDRA_HOST

See Also:

Constant Field Values

FORCE_TABLE_CREATION_FLAG

public static final String FORCE_TABLE_CREATION_FLAG

See Also:

Constant Field Values

Constructor Detail

CassandraEmbeddedServer

public CassandraEmbeddedServer(info.archinnov.achilles.type.TypedMap originalParameters,
                               ConfigMap achillesParameters)

Start a Cassandra embedded server This constructor is not meant to be used directly. Please use the info.archinnov.achilles.embedded.CassandraEmbeddedServerBuilder instead

Parameters:

originalParameters - embedded Cassandra server parameters

achillesParameters - Achilles parameters

Method Detail

getPersistenceManagerFactory

public PersistenceManagerFactory getPersistenceManagerFactory(String keyspaceName)

getPersistenceManager

public PersistenceManager getPersistenceManager(String keyspaceName)

getAsyncManager

public AsyncManager getAsyncManager(String keyspaceName)

getNativeSession

public com.datastax.driver.core.Session getNativeSession(String keyspaceName)

getNativeCluster

public com.datastax.driver.core.Cluster getNativeCluster()

truncateTable

public void truncateTable(String keyspaceName,
                          String tableName)