com.baidu.hugegraph.backend.store.rocksdb

类 RocksDBStore

java.lang.Object

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

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

所有已实现的接口:

BackendStore

直接已知子类:

RocksDBSstStore, RocksDBStore.RocksDBGraphStore, RocksDBStore.RocksDBSchemaStore

public abstract class RocksDBStore
extends AbstractBackendStore<RocksDBSessions.Session>

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	RocksDBStore.RocksDBGraphStore
static class	RocksDBStore.RocksDBSchemaStore Store defines

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

BackendStore.TxState

构造器概要

构造器

构造器和说明
RocksDBStore(BackendStoreProvider provider, String database, String store)

方法概要

限定符和类型	方法和说明
void	beginTx()
void	clear(boolean clearSpace)
void	close()
void	commitTx()
String	database()
BackendFeatures	features()
void	init()
boolean	initialized()
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)
boolean	opened()
protected RocksDBSessions	openSessionPool(HugeConfig config, String dataPath, String walPath, List<String> tableNames)
BackendStoreProvider	provider()
Iterator<BackendEntry>	query(Query query)
Number	queryNumber(Query query)
void	readSnapshot(String parentPath)
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)
void	writeSnapshot(String parentPath)

从类继承的方法 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, setCounterLowest

构造器详细资料

RocksDBStore

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

方法详细资料

registerTableManager

protected void registerTableManager(HugeType type,
                                    RocksDBTable table)

table

protected final RocksDBTable table(HugeType type)

指定者:

table 在类中 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

抛出:

org.rocksdb.RocksDBException

wrapPath

protected String wrapPath(String path)

tableDBMapping

protected Map<String,RocksDBSessions> tableDBMapping()

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)

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

session

protected RocksDBSessions.Session session(HugeType tableType)

指定者:

session 在类中 AbstractBackendStore<RocksDBSessions.Session>

writeSnapshot

public void writeSnapshot(String parentPath)

readSnapshot

public void readSnapshot(String parentPath)