com.baidu.hugegraph.backend.store.rocksdb

Class RocksDBTable

java.lang.Object

com.baidu.hugegraph.backend.store.BackendTable<RocksDBSessions.Session,BackendEntry>

com.baidu.hugegraph.backend.store.rocksdb.RocksDBTable

Direct Known Subclasses:

RocksDBTables.Counters, RocksDBTables.Edge, RocksDBTables.EdgeLabel, RocksDBTables.IndexLabel, RocksDBTables.IndexTable, RocksDBTables.PropertyKey, RocksDBTables.Vertex, RocksDBTables.VertexLabel

public class RocksDBTable
extends BackendTable<RocksDBSessions.Session,BackendEntry>

Nested Class Summary

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

BackendTable.ShardSpliter<Session extends BackendSession>

Constructor Summary

Constructors

Constructor and Description
RocksDBTable(String database, String table)

Method Summary

Modifier and Type	Method and Description
void	append(RocksDBSessions.Session session, BackendEntry entry)
void	clear(RocksDBSessions.Session session)
void	delete(RocksDBSessions.Session session, BackendEntry entry)
void	eliminate(RocksDBSessions.Session session, BackendEntry entry)
void	init(RocksDBSessions.Session session)
void	insert(RocksDBSessions.Session session, BackendEntry entry)
protected static BackendEntryIterator	newEntryIterator(BackendEntry.BackendColumnIterator cols, Query query)
Iterator<BackendEntry>	query(RocksDBSessions.Session session, Query query)
protected BackendEntry.BackendColumnIterator	queryAll(RocksDBSessions.Session session, Query query)
protected BackendEntry.BackendColumnIterator	queryByCond(RocksDBSessions.Session session, ConditionQuery query)
protected BackendEntry.BackendColumnIterator	queryById(RocksDBSessions.Session session, Id id)
protected BackendEntry.BackendColumnIterator	queryByPrefix(RocksDBSessions.Session session, IdPrefixQuery query)
protected BackendEntry.BackendColumnIterator	queryByRange(RocksDBSessions.Session session, IdRangeQuery query)
protected BackendEntry.BackendColumnIterator	queryByRange(RocksDBSessions.Session session, Shard shard, String page)
protected void	registerMetaHandlers()

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

joinTableName, metaDispatcher, registerMetaHandler, table, tableType

Methods inherited from class java.lang.Object

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

Constructor Detail

RocksDBTable

public RocksDBTable(String database,
                    String table)

Method Detail

registerMetaHandlers

protected void registerMetaHandlers()

Overrides:

registerMetaHandlers in class BackendTable<RocksDBSessions.Session,BackendEntry>

init

public void init(RocksDBSessions.Session session)

Specified by:

init in class BackendTable<RocksDBSessions.Session,BackendEntry>

clear

public void clear(RocksDBSessions.Session session)

Specified by:

clear in class BackendTable<RocksDBSessions.Session,BackendEntry>

insert

public void insert(RocksDBSessions.Session session,
                   BackendEntry entry)

Specified by:

insert in class BackendTable<RocksDBSessions.Session,BackendEntry>

delete

public void delete(RocksDBSessions.Session session,
                   BackendEntry entry)

Specified by:

delete in class BackendTable<RocksDBSessions.Session,BackendEntry>

append

public void append(RocksDBSessions.Session session,
                   BackendEntry entry)

Specified by:

append in class BackendTable<RocksDBSessions.Session,BackendEntry>

eliminate

public void eliminate(RocksDBSessions.Session session,
                      BackendEntry entry)

Specified by:

eliminate in class BackendTable<RocksDBSessions.Session,BackendEntry>

query

public Iterator<BackendEntry> query(RocksDBSessions.Session session,
                                    Query query)

Specified by:

query in class BackendTable<RocksDBSessions.Session,BackendEntry>

queryAll

protected BackendEntry.BackendColumnIterator queryAll(RocksDBSessions.Session session,
                                                      Query query)

queryById

protected BackendEntry.BackendColumnIterator queryById(RocksDBSessions.Session session,
                                                       Id id)

queryByPrefix

protected BackendEntry.BackendColumnIterator queryByPrefix(RocksDBSessions.Session session,
                                                           IdPrefixQuery query)

queryByRange

protected BackendEntry.BackendColumnIterator queryByRange(RocksDBSessions.Session session,
                                                          IdRangeQuery query)

queryByCond

protected BackendEntry.BackendColumnIterator queryByCond(RocksDBSessions.Session session,
                                                         ConditionQuery query)

queryByRange

protected BackendEntry.BackendColumnIterator queryByRange(RocksDBSessions.Session session,
                                                          Shard shard,
                                                          String page)

newEntryIterator

protected static BackendEntryIterator newEntryIterator(BackendEntry.BackendColumnIterator cols,
                                                       Query query)