com.baidu.hugegraph.backend.store.cassandra

类 CassandraStore

java.lang.Object

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

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

所有已实现的接口:

BackendStore

直接已知子类:

CassandraStore.CassandraGraphStore, CassandraStore.CassandraSchemaStore

public abstract class CassandraStore
extends AbstractBackendStore<CassandraSessionPool.Session>

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	CassandraStore.CassandraGraphStore
static class	CassandraStore.CassandraSchemaStore Store defines

从接口继承的嵌套类/接口 com.baidu.hugegraph.backend.store.BackendStore

BackendStore.TxState

构造器概要

构造器

构造器和说明
CassandraStore(BackendStoreProvider provider, String keyspace, String store)

方法概要

限定符和类型	方法和说明
void	beginTx()
protected static CassandraBackendEntry	castBackendEntry(BackendEntry entry)
protected void	checkClusterConnected()
void	clear(boolean clearSpace)
protected void	clearKeyspace()
protected void	clearTables()
void	close()
protected com.datastax.driver.core.Cluster	cluster()
void	commitTx()
String	database()
protected boolean	existsKeyspace()
protected boolean	existsTable(String table)
BackendFeatures	features()
void	init()
boolean	initialized()
protected void	initKeyspace()
protected void	initTables()
void	mutate(BackendMutation mutation)
void	open(HugeConfig config)
boolean	opened()
BackendStoreProvider	provider()
Iterator<BackendEntry>	query(Query query)
Number	queryNumber(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()
void	truncate()
protected void	truncateTables()

从类继承的方法 com.baidu.hugegraph.backend.store.AbstractBackendStore

checkOpened, metadata, metaDispatcher, registerMetaHandler, toString

从类继承的方法 java.lang.Object

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

从接口继承的方法 com.baidu.hugegraph.backend.store.BackendStore

getCounter, increaseCounter, isSchemaStore, nextId, readSnapshot, setCounterLowest, writeSnapshot

构造器详细资料

CassandraStore

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

方法详细资料

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()

opened

public boolean opened()

mutate

public void mutate(BackendMutation mutation)

query

public Iterator<BackendEntry> query(Query query)

queryNumber

public Number queryNumber(Query query)

features

public BackendFeatures features()

init

public void init()

clear

public void clear(boolean clearSpace)

initialized

public boolean initialized()

truncate

public void truncate()

beginTx

public void beginTx()

commitTx

public void commitTx()

rollbackTx

public void rollbackTx()

cluster

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

existsKeyspace

protected boolean existsKeyspace()

existsTable

protected boolean existsTable(String table)

initKeyspace

protected void initKeyspace()

clearKeyspace

protected void clearKeyspace()

initTables

protected void initTables()

clearTables

protected void clearTables()

truncateTables

protected void truncateTables()

tables

protected Collection<CassandraTable> tables()

table

protected final CassandraTable table(HugeType type)

指定者:

table 在类中 AbstractBackendStore<CassandraSessionPool.Session>

session

protected CassandraSessionPool.Session session(HugeType type)

指定者:

session 在类中 AbstractBackendStore<CassandraSessionPool.Session>

checkClusterConnected

protected final void checkClusterConnected()

castBackendEntry

protected static final CassandraBackendEntry castBackendEntry(BackendEntry entry)