com.baidu.hugegraph.backend.store.rocksdb

Class RocksDBStore

java.lang.Object

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

All Implemented Interfaces:

BackendStore

Direct Known Subclasses:

RocksDBSstStore, RocksDBStore.RocksDBGraphStore, RocksDBStore.RocksDBSchemaStore

public abstract class RocksDBStore
extends Object
implements BackendStore

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

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()
<R> R	metadata(HugeType type, String meta, Object[] args)
void	mutate(BackendMutation mutation)
void	open(HugeConfig config)
protected RocksDBSessions	open(HugeConfig config, String dataPath, List<String> tableNames)
protected RocksDBSessions	openSessionPool(HugeConfig config, List<String> tableNames)
BackendStoreProvider	provider()
Iterator<BackendEntry>	query(Query query)
protected void	registerTableManager(HugeType type, RocksDBTable table)
void	rollbackTx()
String	store()
protected RocksDBTable	table(HugeType type)
protected List<String>	tableNames()

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

nextId

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)

tableNames

protected List<String> tableNames()

store

public String store()

Specified by:

store in interface BackendStore

database

public String database()

Specified by:

database in interface BackendStore

provider

public BackendStoreProvider provider()

Specified by:

provider in interface BackendStore

features

public BackendFeatures features()

Specified by:

features in interface BackendStore

open

public void open(HugeConfig config)

Specified by:

open in interface BackendStore

open

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

openSessionPool

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

Throws:

org.rocksdb.RocksDBException

close

public void close()

Specified by:

close in interface BackendStore

mutate

public void mutate(BackendMutation mutation)

Specified by:

mutate in interface BackendStore

query

public Iterator<BackendEntry> query(Query query)

Specified by:

query in interface BackendStore

init

public void init()

Specified by:

init in interface BackendStore

clear

public void clear()

Specified by:

clear in interface BackendStore

beginTx

public void beginTx()

Specified by:

beginTx in interface BackendStore

commitTx

public void commitTx()

Specified by:

commitTx in interface BackendStore

rollbackTx

public void rollbackTx()

Specified by:

rollbackTx in interface BackendStore

metadata

public <R> R metadata(HugeType type,
                      String meta,
                      Object[] args)

Specified by:

metadata in interface BackendStore