com.baidu.hugegraph.backend.store.cassandra

Class CassandraStore

java.lang.Object

com.baidu.hugegraph.backend.store.AbstractBackendStore<CassandraSessionPool.Session>

com.baidu.hugegraph.backend.store.cassandra.CassandraStore

All Implemented Interfaces:

BackendStore

Direct Known Subclasses:

CassandraStore.CassandraGraphStore, CassandraStore.CassandraSchemaStore

public abstract class CassandraStore
extends AbstractBackendStore<CassandraSessionPool.Session>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	CassandraStore.CassandraGraphStore
static class	CassandraStore.CassandraSchemaStore Store defines

Nested classes/interfaces inherited from interface com.baidu.hugegraph.backend.store.BackendStore

BackendStore.TxState

Constructor Summary

Constructors

Constructor and Description
CassandraStore(BackendStoreProvider provider, String keyspace, String store)

Method Summary

Modifier and Type	Method and Description
void	beginTx()
protected static CassandraBackendEntry	castBackendEntry(BackendEntry entry)
protected void	checkClusterConnected()
protected void	checkSessionConnected()
void	clear()
protected void	clearKeyspace()
protected void	clearTables()
void	close()
protected com.datastax.driver.core.Cluster	cluster()
void	commitTx()
String	database()
protected boolean	existsKeyspace()
BackendFeatures	features()
void	init()
protected void	initKeyspace()
protected void	initTables()
void	mutate(BackendMutation mutation)
void	open(HugeConfig config)
BackendStoreProvider	provider()
Iterator<BackendEntry>	query(Query query)
protected void	registerTableManager(HugeType type, CassandraTable table)
void	rollbackTx()
protected CassandraSessionPool.Session	session(HugeType type)
String	store()
protected CassandraTable	table(HugeType type)
protected Collection<CassandraTable>	tables()
String	toString()
void	truncate()
protected void	truncateTables()

Methods inherited from class com.baidu.hugegraph.backend.store.AbstractBackendStore

metadata, metaDispatcher, registerMetaHandler

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.baidu.hugegraph.backend.store.BackendStore

getCounter, increaseCounter, nextId, setCounterLowest

Constructor Detail

CassandraStore

public CassandraStore(BackendStoreProvider provider,
                      String keyspace,
                      String store)

Method Detail

registerTableManager

protected void registerTableManager(HugeType type,
                                    CassandraTable table)

store

public String store()

database

public String database()

provider

public BackendStoreProvider provider()

open

public void open(HugeConfig config)

close

public void close()

mutate

public void mutate(BackendMutation mutation)

query

public Iterator<BackendEntry> query(Query query)

features

public BackendFeatures features()

init

public void init()

clear

public void clear()

truncate

public void truncate()

beginTx

public void beginTx()

commitTx

public void commitTx()

rollbackTx

public void rollbackTx()

toString

public String toString()

Overrides:

toString in class Object

cluster

protected com.datastax.driver.core.Cluster cluster()

initKeyspace

protected void initKeyspace()

clearKeyspace

protected void clearKeyspace()

existsKeyspace

protected boolean existsKeyspace()

initTables

protected void initTables()

clearTables

protected void clearTables()

truncateTables

protected void truncateTables()

tables

protected Collection<CassandraTable> tables()

table

protected final CassandraTable table(HugeType type)

Specified by:

table in class AbstractBackendStore<CassandraSessionPool.Session>

session

protected CassandraSessionPool.Session session(HugeType type)

Specified by:

session in class AbstractBackendStore<CassandraSessionPool.Session>

checkClusterConnected

protected final void checkClusterConnected()

checkSessionConnected

protected final void checkSessionConnected()

castBackendEntry

protected static final CassandraBackendEntry castBackendEntry(BackendEntry entry)