Uses of Class
co.cask.cdap.data2.util.TableId

Packages that use TableId

Package	Description
co.cask.cdap.data.stream	This package contains classes for management and manipulation of stream files.
co.cask.cdap.data2.dataset2.lib.hbase	This package contains HBase implementations of the dataset system v2.
co.cask.cdap.data2.dataset2.lib.table.leveldb	This package contains LevelDB implementations of the table dataset.
co.cask.cdap.data2.transaction.queue	Transaction aware queue implementation.
co.cask.cdap.data2.transaction.queue.hbase	This package contains an HBase implementation of queues.
co.cask.cdap.data2.transaction.stream	This package contains transaction stream consumer classes for maintaining stateful consumption of stream entries.
co.cask.cdap.data2.transaction.stream.hbase	This package contains class for stream consumer implementation that uses HBase as state store.
co.cask.cdap.data2.transaction.stream.leveldb	This package contains class for stream consumer implementation that uses LevelDB as state store.
co.cask.cdap.data2.util
co.cask.cdap.data2.util.hbase

Uses of TableId in co.cask.cdap.data.stream

Methods in co.cask.cdap.data.stream that return TableId

Modifier and Type	Method and Description
static TableId	StreamUtils.getStateStoreTableId(Id.Namespace namespace) Gets a TableId for stream consumer state stores within a given namespace.

Uses of TableId in co.cask.cdap.data2.dataset2.lib.hbase

Fields in co.cask.cdap.data2.dataset2.lib.hbase declared as TableId

Modifier and Type	Field and Description
protected TableId	AbstractHBaseDataSetAdmin.tableId

Constructors in co.cask.cdap.data2.dataset2.lib.hbase with parameters of type TableId

Constructor and Description
AbstractHBaseDataSetAdmin(TableId tableId, Configuration hConf, HBaseTableUtil tableUtil)

Uses of TableId in co.cask.cdap.data2.dataset2.lib.table.leveldb

Methods in co.cask.cdap.data2.dataset2.lib.table.leveldb that return types with arguments of type TableId

Modifier and Type	Method and Description
Map<TableId,LevelDBTableService.TableStats>	LevelDBTableService.getTableStats() Gets tables stats.

Uses of TableId in co.cask.cdap.data2.transaction.queue

Methods in co.cask.cdap.data2.transaction.queue that return TableId

Modifier and Type	Method and Description
TableId	AbstractQueueAdmin.getDataTableId(Id.Flow flowId)
TableId	AbstractQueueAdmin.getDataTableId(QueueName queueName) This determines the actual TableId from the table name prefix and the name of the queue.

Uses of TableId in co.cask.cdap.data2.transaction.queue.hbase

Methods in co.cask.cdap.data2.transaction.queue.hbase that return TableId

Modifier and Type	Method and Description
static TableId	HBaseQueueAdmin.getConfigTableId(QueueName queueName)
static TableId	HBaseQueueAdmin.getConfigTableId(String namespace)
TableId	HBaseQueueAdmin.getDataTableId(Id.Flow flowId)
TableId	HBaseQueueAdmin.getDataTableId(Id.Flow flowId, QueueConstants.QueueType queueType)
TableId	HBaseQueueAdmin.getDataTableId(QueueName queueName)
TableId	HBaseQueueAdmin.getDataTableId(QueueName queueName, QueueConstants.QueueType queueType)

Methods in co.cask.cdap.data2.transaction.queue.hbase with parameters of type TableId

Modifier and Type	Method and Description
org.apache.hadoop.hbase.client.HTable	HBaseQueueClientFactory.createHTable(TableId tableId)

Uses of TableId in co.cask.cdap.data2.transaction.stream

Methods in co.cask.cdap.data2.transaction.stream with parameters of type TableId

Modifier and Type	Method and Description
protected abstract StreamConsumer	AbstractStreamFileConsumerFactory.create(TableId tableId, StreamConfig streamConfig, ConsumerConfig consumerConfig, StreamConsumerStateStore stateStore, StreamConsumerState beginConsumerState, FileReader<StreamEventOffset,Iterable<StreamFileOffset>> reader, ReadFilter extraFilter) Creates a StreamConsumer.
protected abstract void	AbstractStreamFileConsumerFactory.dropTable(TableId tableId) Deletes process states table.

Uses of TableId in co.cask.cdap.data2.transaction.stream.hbase

Methods in co.cask.cdap.data2.transaction.stream.hbase with parameters of type TableId

Modifier and Type	Method and Description
protected StreamConsumer	HBaseStreamFileConsumerFactory.create(TableId tableId, StreamConfig streamConfig, ConsumerConfig consumerConfig, StreamConsumerStateStore stateStore, StreamConsumerState beginConsumerState, FileReader<StreamEventOffset,Iterable<StreamFileOffset>> reader, ReadFilter extraFilter)
protected void	HBaseStreamFileConsumerFactory.dropTable(TableId tableId)

Uses of TableId in co.cask.cdap.data2.transaction.stream.leveldb

Methods in co.cask.cdap.data2.transaction.stream.leveldb that return TableId

Modifier and Type	Method and Description
static TableId	LevelDBNameConverter.from(String levelDBTableName)

Methods in co.cask.cdap.data2.transaction.stream.leveldb with parameters of type TableId

Modifier and Type	Method and Description
protected StreamConsumer	LevelDBStreamFileConsumerFactory.create(TableId tableId, StreamConfig streamConfig, ConsumerConfig consumerConfig, StreamConsumerStateStore stateStore, StreamConsumerState beginConsumerState, FileReader<StreamEventOffset,Iterable<StreamFileOffset>> reader, ReadFilter extraFilter)
protected void	LevelDBStreamFileConsumerFactory.dropTable(TableId tableId)

Uses of TableId in co.cask.cdap.data2.util

Methods in co.cask.cdap.data2.util that return TableId

Modifier and Type	Method and Description
static TableId	TableId.from(Id.Namespace namespaceId, String tableName)
static TableId	TableId.from(String namespace, String tableName)

Uses of TableId in co.cask.cdap.data2.util.hbase

Methods in co.cask.cdap.data2.util.hbase that return TableId

Modifier and Type	Method and Description
abstract TableId	HTableNameConverter.from(org.apache.hadoop.hbase.HTableDescriptor htd) Returns TableId for the table represented by the given HTableDescriptor.
TableId	HTableNameConverter.PrefixedTableId.getTableId()

Methods in co.cask.cdap.data2.util.hbase that return types with arguments of type TableId

Modifier and Type	Method and Description
abstract Map<TableId,HBaseTableUtil.TableStats>	HBaseTableUtil.getTableStats(org.apache.hadoop.hbase.client.HBaseAdmin admin) Collects HBase table stats //TODO: Explore the possiblitity of returning a Map<TableId, TableStats>
abstract List<TableId>	HBaseTableUtil.listTables(org.apache.hadoop.hbase.client.HBaseAdmin admin) Lists all tables
abstract List<TableId>	HBaseTableUtil.listTablesInNamespace(org.apache.hadoop.hbase.client.HBaseAdmin admin, Id.Namespace namespaceId) Lists all tables in the specified namespace

Methods in co.cask.cdap.data2.util.hbase with parameters of type TableId

Modifier and Type	Method and Description
abstract HTableDescriptorBuilder	HBaseTableUtil.buildHTableDescriptor(TableId tableId) Creates a new HTableDescriptorBuilder which may contain an HBase namespace depending on the HBase version
abstract org.apache.hadoop.hbase.client.HTable	HBaseTableUtil.createHTable(Configuration conf, TableId tableId) Creates a new HTable which may contain an HBase namespace depending on the HBase version
void	HBaseTableUtil.createTableIfNotExists(org.apache.hadoop.hbase.client.HBaseAdmin admin, TableId tableId, org.apache.hadoop.hbase.HTableDescriptor tableDescriptor) Create a hbase table if it does not exist.
void	HBaseTableUtil.createTableIfNotExists(org.apache.hadoop.hbase.client.HBaseAdmin admin, TableId tableId, org.apache.hadoop.hbase.HTableDescriptor tableDescriptor, byte[][] splitKeys) Creates a hbase table if it does not exists.
void	HBaseTableUtil.createTableIfNotExists(org.apache.hadoop.hbase.client.HBaseAdmin admin, TableId tableId, org.apache.hadoop.hbase.HTableDescriptor tableDescriptor, byte[][] splitKeys, long timeout, TimeUnit timeoutUnit) Create a hbase table if it does not exist.
abstract void	HBaseTableUtil.deleteTable(org.apache.hadoop.hbase.client.HBaseAdmin admin, TableId tableId) Delete an HBase table
abstract void	HBaseTableUtil.disableTable(org.apache.hadoop.hbase.client.HBaseAdmin admin, TableId tableId) Disable an HBase table
void	HBaseTableUtil.dropTable(org.apache.hadoop.hbase.client.HBaseAdmin admin, TableId tableId) Disables and deletes a table.
abstract void	HBaseTableUtil.enableTable(org.apache.hadoop.hbase.client.HBaseAdmin admin, TableId tableId) Enable an HBase table
protected String	HTableNameConverter.getHBaseTableName(String tablePrefix, TableId tableId)
abstract org.apache.hadoop.hbase.HTableDescriptor	HBaseTableUtil.getHTableDescriptor(org.apache.hadoop.hbase.client.HBaseAdmin admin, TableId tableId) Constructs a HTableDescriptor which may contain an HBase namespace for an existing table
abstract List<org.apache.hadoop.hbase.HRegionInfo>	HBaseTableUtil.getTableRegions(org.apache.hadoop.hbase.client.HBaseAdmin admin, TableId tableId) Returns a list of HRegionInfo for the specified TableId
abstract boolean	HBaseTableUtil.tableExists(org.apache.hadoop.hbase.client.HBaseAdmin admin, TableId tableId) Check if an HBase table exists
void	HBaseTableUtil.truncateTable(org.apache.hadoop.hbase.client.HBaseAdmin admin, TableId tableId) Truncates a table

Method parameters in co.cask.cdap.data2.util.hbase with type arguments of type TableId

Modifier and Type	Method and Description
void	HBaseTableUtil.deleteAllInNamespace(org.apache.hadoop.hbase.client.HBaseAdmin admin, Id.Namespace namespaceId, com.google.common.base.Predicate<TableId> predicate) Deletes all tables in the specified namespace that satisfy the given Predicate.