com.baidu.hugegraph.backend.store.rocksdb

类 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

嵌套类概要

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

RocksDBSessions.Countable, RocksDBSessions.Session

构造器概要

构造器

构造器和说明
RocksDBStdSessions(HugeConfig config, String database, String store, String dataPath, String walPath)
RocksDBStdSessions(HugeConfig config, String database, String store, String dataPath, String walPath, List<String> cfNames)

方法概要

限定符和类型	方法和说明
RocksDBSessions	copy(HugeConfig config, String database, String store)
void	createSnapshot(String parentPath)
void	createTable(String... tables)
static String	decode(byte[] bytes)
protected void	doClose()
void	dropTable(String... tables)
static byte[]	encode(String string)
boolean	existsTable(String table)
void	forceCloseRocksDB()
static void	initOptions(HugeConfig conf, org.rocksdb.DBOptionsInterface<?> db, org.rocksdb.MutableDBOptionsInterface<?> mdb, org.rocksdb.ColumnFamilyOptionsInterface<?> cf, org.rocksdb.MutableColumnFamilyOptionsInterface<?> mcf)
static Set<String>	listCFs(String path)
protected RocksDBSessions.Session	newSession()
void	open()
protected boolean	opened()
Set<String>	openedTables()
List<String>	property(String property)
void	reload()
RocksDBSessions.Session	session()

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

close, closed, config, forceResetSessions, getOrNewSession, toString, useSession

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

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

构造器详细资料

RocksDBStdSessions

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

抛出:

org.rocksdb.RocksDBException

RocksDBStdSessions

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

抛出:

org.rocksdb.RocksDBException

方法详细资料

open

public void open()
          throws Exception

指定者:

open 在类中 BackendSessionPool

抛出:

Exception

opened

protected boolean opened()

指定者:

opened 在类中 BackendSessionPool

openedTables

public Set<String> openedTables()

指定者:

openedTables 在类中 RocksDBSessions

createTable

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

指定者:

createTable 在类中 RocksDBSessions

抛出:

org.rocksdb.RocksDBException

dropTable

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

指定者:

dropTable 在类中 RocksDBSessions

抛出:

org.rocksdb.RocksDBException

reload

public void reload()
            throws org.rocksdb.RocksDBException

指定者:

reload 在类中 RocksDBSessions

抛出:

org.rocksdb.RocksDBException

forceCloseRocksDB

public void forceCloseRocksDB()

指定者:

forceCloseRocksDB 在类中 RocksDBSessions

existsTable

public boolean existsTable(String table)

指定者:

existsTable 在类中 RocksDBSessions

property

public List<String> property(String property)

指定者:

property 在类中 RocksDBSessions

copy

public RocksDBSessions copy(HugeConfig config,
                            String database,
                            String store)

指定者:

copy 在类中 RocksDBSessions

createSnapshot

public void createSnapshot(String parentPath)

指定者:

createSnapshot 在类中 RocksDBSessions

session

public final RocksDBSessions.Session session()

指定者:

session 在类中 RocksDBSessions

newSession

protected final RocksDBSessions.Session newSession()

指定者:

newSession 在类中 BackendSessionPool

doClose

protected void doClose()

指定者:

doClose 在类中 BackendSessionPool

listCFs

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

抛出:

org.rocksdb.RocksDBException

initOptions

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

encode

public static final byte[] encode(String string)

decode

public static final String decode(byte[] bytes)