org.wicketstuff.datastores.cassandra

Class CassandraDataStore

java.lang.Object

org.wicketstuff.datastores.cassandra.CassandraDataStore

All Implemented Interfaces:

org.apache.wicket.pageStore.IDataStore

public class CassandraDataStore
extends Object
implements org.apache.wicket.pageStore.IDataStore

An IDataStore that saves the pages' bytes in Apache Cassandra

Constructor Summary

Constructors

Constructor and Description
CassandraDataStore(com.datastax.driver.core.Cluster cluster, ICassandraSettings settings) Constructor.
CassandraDataStore(ICassandraSettings settings) Constructor.

Method Summary

Methods

Modifier and Type	Method and Description
boolean	canBeAsynchronous()
protected com.datastax.driver.core.KeyspaceMetadata	createKeyspaceIfNecessary(String keyspaceName, com.datastax.driver.core.Metadata metadata) Creates the Cassandra keyspace where the data will be stored if it doesn't exists already
protected void	createTableIfNecessary(String keyspaceName, com.datastax.driver.core.KeyspaceMetadata keyspaceMetadata) Creates the table where the data will be stored if it doesn't exists already
void	destroy()
byte[]	getData(String sessionId, int pageId)
boolean	isReplicated()
void	removeData(String sessionId)
void	removeData(String sessionId, int pageId)
void	storeData(String sessionId, int pageId, byte[] data)

Methods inherited from class java.lang.Object

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

Constructor Detail

CassandraDataStore

public CassandraDataStore(ICassandraSettings settings)

Constructor. Creates a Cluster based on the contact points provided by the passed settings

Parameters:

settings - The various settings

CassandraDataStore

public CassandraDataStore(com.datastax.driver.core.Cluster cluster,
                  ICassandraSettings settings)

Constructor. Initializes the connection to the Cassandra cluster and creates the keyspace and/or table if necessary.

Parameters:

cluster - The Cassandra cluster

settings - The various settings

Method Detail

getData

public byte[] getData(String sessionId,
             int pageId)

Specified by:

getData in interface org.apache.wicket.pageStore.IDataStore

removeData

public void removeData(String sessionId,
              int pageId)

Specified by:

removeData in interface org.apache.wicket.pageStore.IDataStore

removeData

public void removeData(String sessionId)

Specified by:

removeData in interface org.apache.wicket.pageStore.IDataStore

storeData

public void storeData(String sessionId,
             int pageId,
             byte[] data)

Specified by:

storeData in interface org.apache.wicket.pageStore.IDataStore

destroy

public void destroy()

Specified by:

destroy in interface org.apache.wicket.pageStore.IDataStore

isReplicated

public boolean isReplicated()

Specified by:

isReplicated in interface org.apache.wicket.pageStore.IDataStore

canBeAsynchronous

public boolean canBeAsynchronous()

Specified by:

canBeAsynchronous in interface org.apache.wicket.pageStore.IDataStore

createTableIfNecessary

protected void createTableIfNecessary(String keyspaceName,
                          com.datastax.driver.core.KeyspaceMetadata keyspaceMetadata)

Creates the table where the data will be stored if it doesn't exists already

Parameters:

keyspaceName - The name of the keyspace where to create the table

keyspaceMetadata - The keyspace metadata. May be null if this is the first usage of this store with these settings

createKeyspaceIfNecessary

protected com.datastax.driver.core.KeyspaceMetadata createKeyspaceIfNecessary(String keyspaceName,
                                                                  com.datastax.driver.core.Metadata metadata)

Creates the Cassandra keyspace where the data will be stored if it doesn't exists already

Parameters:

keyspaceName - The name of the keyspace

metadata - The cluster metadata

Returns:

The keyspace metadata. May be null if the the metadata doesn't exists yet.