com.baidu.hugegraph.backend.store.rocksdb

Class RocksDBStore

java.lang.Object

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

com.baidu.hugegraph.backend.store.rocksdb.RocksDBStore

All Implemented Interfaces:

BackendStore

Direct Known Subclasses:

RocksDBSstStore, RocksDBStore.RocksDBGraphStore, RocksDBStore.RocksDBSchemaStore

public abstract class RocksDBStore
extends AbstractBackendStore<RocksDBSessions.Session>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RocksDBStore.RocksDBGraphStore
static class	RocksDBStore.RocksDBSchemaStore Store defines

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

BackendStore.TxState

Field Summary

Fields

Modifier and Type	Field and Description
protected static ConcurrentMap<String,RocksDBSessions>	dbs

Constructor Summary

Constructors

Constructor and Description
RocksDBStore(BackendStoreProvider provider, String database, String store)

Method Summary

Modifier and Type	Method and Description
void	beginTx()
void	clear()
void	close()
void	commitTx()
String	database()
BackendFeatures	features()
void	init()
void	mutate(BackendMutation mutation)
void	open(HugeConfig config)
protected RocksDBSessions	open(HugeConfig config, List<String> tableNames)
protected RocksDBSessions	open(HugeConfig config, String dataPath, String walPath, List<String> tableNames)
protected RocksDBSessions	openSessionPool(HugeConfig config, String dataPath, String walPath, List<String> tableNames)
BackendStoreProvider	provider()
Iterator<BackendEntry>	query(Query query)
protected void	registerTableManager(HugeType type, RocksDBTable table)
void	rollbackTx()
protected RocksDBSessions.Session	session(HugeType tableType)
String	store()
protected RocksDBTable	table(HugeType type)
protected Map<String,RocksDBSessions>	tableDBMapping()
protected List<String>	tableNames()
void	truncate()
protected String	wrapPath(String path)

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, toString, wait, wait, wait

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

getCounter, increaseCounter, nextId, setCounterLowest

Field Detail

dbs

protected static final ConcurrentMap<String,RocksDBSessions> dbs

Constructor Detail

RocksDBStore

public RocksDBStore(BackendStoreProvider provider,
                    String database,
                    String store)

Method Detail

registerTableManager

protected void registerTableManager(HugeType type,
                                    RocksDBTable table)

table

protected final RocksDBTable table(HugeType type)

Specified by:

table in class AbstractBackendStore<RocksDBSessions.Session>

tableNames

protected List<String> tableNames()

store

public String store()

database

public String database()

provider

public BackendStoreProvider provider()

features

public BackendFeatures features()

open

public void open(HugeConfig config)

open

protected RocksDBSessions open(HugeConfig config,
                               List<String> tableNames)

open

protected RocksDBSessions open(HugeConfig config,
                               String dataPath,
                               String walPath,
                               List<String> tableNames)

openSessionPool

protected RocksDBSessions openSessionPool(HugeConfig config,
                                          String dataPath,
                                          String walPath,
                                          List<String> tableNames)
                                   throws org.rocksdb.RocksDBException

Throws:

org.rocksdb.RocksDBException

wrapPath

protected String wrapPath(String path)

tableDBMapping

protected Map<String,RocksDBSessions> tableDBMapping()

close

public void close()

mutate

public void mutate(BackendMutation mutation)

query

public Iterator<BackendEntry> query(Query query)

init

public void init()

clear

public void clear()

truncate

public void truncate()

beginTx

public void beginTx()

commitTx

public void commitTx()

rollbackTx

public void rollbackTx()

session

protected RocksDBSessions.Session session(HugeType tableType)

Specified by:

session in class AbstractBackendStore<RocksDBSessions.Session>