com.baidu.hugegraph.backend.store.rocksdb

Class RocksDBStdSessions

java.lang.Object

com.baidu.hugegraph.backend.store.BackendSessionPool

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

com.baidu.hugegraph.backend.store.rocksdb.RocksDBStdSessions

public class RocksDBStdSessions
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
RocksDBStdSessions(HugeConfig config, String dataPath, String walPath, String database, String store)
RocksDBStdSessions(HugeConfig config, String dataPath, String walPath, String database, String store, List<String> cfNames)

Method Summary

Modifier and Type	Method and Description
void	createTable(String table)
static String	decode(byte[] bytes)
protected void	doClose()
void	dropTable(String table)
static byte[]	encode(String string)
static byte[]	increaseOne(byte[] bytes)
static void	initOptions(HugeConfig conf, org.rocksdb.DBOptionsInterface<?> db, org.rocksdb.ColumnFamilyOptionsInterface<?> cf, org.rocksdb.MutableColumnFamilyOptionsInterface<?> mcf)
static Set<String>	listCFs(String path)
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

RocksDBStdSessions

public RocksDBStdSessions(HugeConfig config,
                          String dataPath,
                          String walPath,
                          String database,
                          String store)
                   throws org.rocksdb.RocksDBException

Throws:

org.rocksdb.RocksDBException

RocksDBStdSessions

public RocksDBStdSessions(HugeConfig config,
                          String dataPath,
                          String walPath,
                          String database,
                          String store,
                          List<String> cfNames)
                   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

listCFs

public static Set<String> listCFs(String path)
                           throws org.rocksdb.RocksDBException

Throws:

org.rocksdb.RocksDBException

initOptions

public static void initOptions(HugeConfig conf,
                               org.rocksdb.DBOptionsInterface<?> db,
                               org.rocksdb.ColumnFamilyOptionsInterface<?> cf,
                               org.rocksdb.MutableColumnFamilyOptionsInterface<?> mcf)

encode

public static final byte[] encode(String string)

decode

public static final String decode(byte[] bytes)

increaseOne

public static final byte[] increaseOne(byte[] bytes)