public final class HBaseTableFactory extends Object implements TableFactory
TableFactory for creating messaging tables backed by HBase.
This factory memorize what HBase tables are already exists. If the table get deleted externally,
it relies on the HBaseExceptionHandler to cleanup the in memory cache so that on the next
request, the table will be recreated and the cache will get repopulated.
Caching the the table descriptor is ok since all changes of the table descriptor should be done via
the TMS.| Modifier and Type | Field and Description |
|---|---|
static byte[] |
COLUMN_FAMILY |
| Modifier and Type | Method and Description |
|---|---|
MessageTable |
createMessageTable(String tableName) |
MetadataTable |
createMetadataTable(String tableName) |
PayloadTable |
createPayloadTable(String tableName) |
void |
disableMessageTable(String tableName) |
void |
disablePayloadTable(String tableName) |
void |
upgradeMessageTable(String tableName) |
void |
upgradePayloadTable(String tableName) |
public MetadataTable createMetadataTable(String tableName) throws IOException
createMetadataTable in interface TableFactoryIOExceptionpublic MessageTable createMessageTable(String tableName) throws IOException
createMessageTable in interface TableFactoryIOExceptionpublic PayloadTable createPayloadTable(String tableName) throws IOException
createPayloadTable in interface TableFactoryIOExceptionpublic void upgradeMessageTable(String tableName) throws IOException
IOExceptionpublic void upgradePayloadTable(String tableName) throws IOException
IOExceptionpublic void disableMessageTable(String tableName) throws IOException
IOExceptionpublic void disablePayloadTable(String tableName) throws IOException
IOExceptionCopyright © 2017 Cask Data, Inc. Licensed under the Apache License, Version 2.0.