com.baidu.hugegraph.backend.store.rocksdbsst

Class RocksDBSstSessions

java.lang.Object

com.baidu.hugegraph.backend.store.BackendSessionPool

com.baidu.hugegraph.backend.store.rocksdb.RocksDBSessions

com.baidu.hugegraph.backend.store.rocksdbsst.RocksDBSstSessions

public class RocksDBSstSessions
extends RocksDBSessions

Nested Class Summary

Nested classes/interfaces inherited from class com.baidu.hugegraph.backend.store.rocksdb.RocksDBSessions

RocksDBSessions.Session

Constructor Summary

Constructors

Constructor and Description
RocksDBSstSessions(HugeConfig conf, String dataPath, String database, String store)
RocksDBSstSessions(HugeConfig config, String dataPath, String database, String store, List<String> tableNames)

Method Summary

Modifier and Type	Method and Description
void	createTable(String table)
protected void	doClose()
void	dropTable(String table)
protected RocksDBSessions.Session	newSession()
void	open(HugeConfig config)
protected boolean	opened()
Set<String>	openedTables()
RocksDBSessions.Session	session()

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

close, closed, closeSession, getOrNewSession, toString, useSession

Methods inherited from class java.lang.Object

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

Constructor Detail

RocksDBSstSessions

public RocksDBSstSessions(HugeConfig conf,
                          String dataPath,
                          String database,
                          String store)

RocksDBSstSessions

public RocksDBSstSessions(HugeConfig config,
                          String dataPath,
                          String database,
                          String store,
                          List<String> tableNames)
                   throws org.rocksdb.RocksDBException

Throws:

org.rocksdb.RocksDBException

Method Detail

open

public void open(HugeConfig config)
          throws Exception

Specified by:

open in class BackendSessionPool

Throws:

Exception

opened

protected boolean opened()

Specified by:

opened in class BackendSessionPool

openedTables

public Set<String> openedTables()

Specified by:

openedTables in class RocksDBSessions

createTable

public void createTable(String table)
                 throws org.rocksdb.RocksDBException

Specified by:

createTable in class RocksDBSessions

Throws:

org.rocksdb.RocksDBException

dropTable

public void dropTable(String table)
               throws org.rocksdb.RocksDBException

Specified by:

dropTable in class RocksDBSessions

Throws:

org.rocksdb.RocksDBException

session

public final RocksDBSessions.Session session()

Specified by:

session in class RocksDBSessions

newSession

protected final RocksDBSessions.Session newSession()

Specified by:

newSession in class BackendSessionPool

doClose

protected void doClose()

Specified by:

doClose in class BackendSessionPool