public abstract class HbaseStore extends AbstractBackendStore<HbaseSessions.Session>
| Modifier and Type | Class and Description |
|---|---|
static class |
HbaseStore.HbaseGraphStore |
static class |
HbaseStore.HbaseSchemaStore
Store defines
|
static class |
HbaseStore.HbaseSystemStore |
BackendStore.TxState| Constructor and Description |
|---|
HbaseStore(BackendStoreProvider provider,
String namespace,
String store,
boolean enablePartition) |
| Modifier and Type | Method and Description |
|---|---|
void |
beginTx() |
void |
clear(boolean clearSpace) |
void |
close() |
void |
commitTx() |
String |
database() |
BackendFeatures |
features() |
void |
init() |
boolean |
initialized() |
void |
mutate(BackendMutation mutation) |
String |
namespace() |
void |
open(HugeConfig config) |
boolean |
opened() |
BackendStoreProvider |
provider() |
Iterator<BackendEntry> |
query(Query query) |
Number |
queryNumber(Query query) |
protected void |
registerTableManager(HugeType type,
HbaseTable table) |
void |
rollbackTx() |
protected HbaseSessions.Session |
session(HugeType type) |
String |
store() |
protected HbaseTable |
table(HugeType type) |
protected List<String> |
tableNames() |
void |
truncate() |
checkOpened, metadata, metaDispatcher, registerMetaHandler, storedVersion, systemSchemaStore, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitcheckAndRegisterOlapTable, clearOlapTable, createOlapTable, createSnapshot, getCounter, increaseCounter, isSchemaStore, nextId, olapTableName, olapTableName, removeOlapTable, resumeSnapshot, setCounterLowestpublic HbaseStore(BackendStoreProvider provider, String namespace, String store, boolean enablePartition)
protected void registerTableManager(HugeType type, HbaseTable table)
protected final HbaseTable table(HugeType type)
table in class AbstractBackendStore<HbaseSessions.Session>protected HbaseSessions.Session session(HugeType type)
session in class AbstractBackendStore<HbaseSessions.Session>public String namespace()
public String store()
public String database()
public BackendStoreProvider provider()
public BackendFeatures features()
public void open(HugeConfig config)
public void close()
public boolean opened()
public void mutate(BackendMutation mutation)
public Iterator<BackendEntry> query(Query query)
public void init()
public void clear(boolean clearSpace)
public boolean initialized()
public void truncate()
public void beginTx()
public void commitTx()
public void rollbackTx()
Copyright © 2017–2024 The Apache Software Foundation. All rights reserved.