com.baidu.hugegraph.backend.store.rocksdb

类 RocksDBTable

java.lang.Object

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

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

直接已知子类:

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

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

嵌套类概要

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

BackendTable.ShardSpliter<Session extends BackendSession>

构造器概要

构造器

构造器和说明
RocksDBTable(String database, String table)

方法概要

限定符和类型	方法和说明
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)
protected BackendEntry.BackendColumnIterator	getById(RocksDBSessions.Session session, Id id)
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	queryBy(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)
Number	queryNumber(RocksDBSessions.Session session, Query query)
protected void	registerMetaHandlers()
protected static long	sizeOfBackendEntry(BackendEntry entry)

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

joinTableName, metaDispatcher, registerMetaHandler, table, tableType

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

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

构造器详细资料

RocksDBTable

public RocksDBTable(String database,
                    String table)

方法详细资料

registerMetaHandlers

protected void registerMetaHandlers()

覆盖:

registerMetaHandlers 在类中 BackendTable<RocksDBSessions.Session,BackendEntry>

init

public void init(RocksDBSessions.Session session)

指定者:

init 在类中 BackendTable<RocksDBSessions.Session,BackendEntry>

clear

public void clear(RocksDBSessions.Session session)

指定者:

clear 在类中 BackendTable<RocksDBSessions.Session,BackendEntry>

insert

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

指定者:

insert 在类中 BackendTable<RocksDBSessions.Session,BackendEntry>

delete

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

指定者:

delete 在类中 BackendTable<RocksDBSessions.Session,BackendEntry>

append

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

指定者:

append 在类中 BackendTable<RocksDBSessions.Session,BackendEntry>

eliminate

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

指定者:

eliminate 在类中 BackendTable<RocksDBSessions.Session,BackendEntry>

queryNumber

public Number queryNumber(RocksDBSessions.Session session,
                          Query query)

指定者:

queryNumber 在类中 BackendTable<RocksDBSessions.Session,BackendEntry>

query

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

指定者:

query 在类中 BackendTable<RocksDBSessions.Session,BackendEntry>

queryBy

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

queryAll

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

queryById

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

getById

protected BackendEntry.BackendColumnIterator getById(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 final BackendEntryIterator newEntryIterator(BackendEntry.BackendColumnIterator cols,
                                                             Query query)

sizeOfBackendEntry

protected static final long sizeOfBackendEntry(BackendEntry entry)