co.cask.cdap.data2.util.hbase

Class HBase98TableUtil

java.lang.Object

co.cask.cdap.data2.util.hbase.HBaseTableUtil

co.cask.cdap.data2.util.hbase.HBase98TableUtil

public class HBase98TableUtil
extends HBaseTableUtil

Nested Class Summary

Nested classes/interfaces inherited from class co.cask.cdap.data2.util.hbase.HBaseTableUtil

HBaseTableUtil.BloomType, HBaseTableUtil.CompressionType, HBaseTableUtil.CoprocessorInfo, HBaseTableUtil.TableStats

Field Summary

Fields inherited from class co.cask.cdap.data2.util.hbase.HBaseTableUtil

CDAP_VERSION, CFG_HBASE_TABLE_COMPRESSION, DEFAULT_WRITE_BUFFER_SIZE, MAX_CREATE_TABLE_WAIT, namespaceQueryAdmin, tablePrefix

Constructor Summary

Constructors

Constructor and Description
HBase98TableUtil()

Method Summary

Methods

Modifier and Type	Method and Description
HTableDescriptorBuilder	buildHTableDescriptor(org.apache.hadoop.hbase.HTableDescriptor tableDescriptorToCopy)
HTableDescriptorBuilder	buildHTableDescriptor(TableId tableId)
org.apache.hadoop.hbase.client.HTable	createHTable(Configuration conf, TableId tableId)
void	createNamespaceIfNotExists(org.apache.hadoop.hbase.client.HBaseAdmin admin, String namespace)
void	deleteNamespaceIfExists(org.apache.hadoop.hbase.client.HBaseAdmin admin, String namespace)
void	deleteTable(org.apache.hadoop.hbase.client.HBaseAdmin admin, TableId tableId)
void	disableTable(org.apache.hadoop.hbase.client.HBaseAdmin admin, TableId tableId)
void	enableTable(org.apache.hadoop.hbase.client.HBaseAdmin admin, TableId tableId)
HBaseTableUtil.BloomType	getBloomFilter(org.apache.hadoop.hbase.HColumnDescriptor columnDescriptor)
HBaseTableUtil.CompressionType	getCompression(org.apache.hadoop.hbase.HColumnDescriptor columnDescriptor)
Class<? extends org.apache.hadoop.hbase.Coprocessor>	getDequeueScanObserverClassForVersion()
org.apache.hadoop.hbase.HTableDescriptor	getHTableDescriptor(org.apache.hadoop.hbase.client.HBaseAdmin admin, TableId tableId)
protected HTableNameConverter	getHTableNameConverter()
Class<? extends org.apache.hadoop.hbase.Coprocessor>	getIncrementHandlerClassForVersion()
Class<? extends org.apache.hadoop.hbase.Coprocessor>	getQueueRegionObserverClassForVersion()
List<org.apache.hadoop.hbase.HRegionInfo>	getTableRegions(org.apache.hadoop.hbase.client.HBaseAdmin admin, TableId tableId)
Class<? extends org.apache.hadoop.hbase.Coprocessor>	getTransactionDataJanitorClassForVersion()
boolean	hasNamespace(org.apache.hadoop.hbase.client.HBaseAdmin admin, String namespace)
List<TableId>	listTables(org.apache.hadoop.hbase.client.HBaseAdmin admin)
List<TableId>	listTablesInNamespace(org.apache.hadoop.hbase.client.HBaseAdmin admin, String namespaceId)
void	modifyTable(org.apache.hadoop.hbase.client.HBaseAdmin admin, org.apache.hadoop.hbase.HTableDescriptor tableDescriptor)
void	setBloomFilter(org.apache.hadoop.hbase.HColumnDescriptor columnDescriptor, HBaseTableUtil.BloomType type)
void	setCompression(org.apache.hadoop.hbase.HColumnDescriptor columnDescriptor, HBaseTableUtil.CompressionType type)
boolean	tableExists(org.apache.hadoop.hbase.client.HBaseAdmin admin, TableId tableId)

Methods inherited from class co.cask.cdap.data2.util.hbase.HBaseTableUtil

buildDelete, buildDelete, buildGet, buildGet, buildPut, buildPut, buildScan, buildScan, createCoProcessorJar, createHTableId, createTableIfNotExists, createTableIfNotExists, createTableIfNotExists, deleteAllInNamespace, deleteAllInNamespace, dropTable, getCoprocessorInfo, getHBaseNamespace, getHBaseNamespace, getHBaseToCDAPNamespaceMap, getSplitKeys, getTableStats, getVersion, isCDAPTable, setCConf, setNamespaceQueryAdmin, setTablePrefix, setTablePrefix, setVersion, setVersion, truncateTable

Methods inherited from class java.lang.Object

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

Constructor Detail

HBase98TableUtil

public HBase98TableUtil()

Method Detail

createHTable

public org.apache.hadoop.hbase.client.HTable createHTable(Configuration conf,
                                                 TableId tableId)
                                                   throws IOException

Specified by:

createHTable in class HBaseTableUtil

Throws:

IOException

buildHTableDescriptor

public HTableDescriptorBuilder buildHTableDescriptor(TableId tableId)

Specified by:

buildHTableDescriptor in class HBaseTableUtil

buildHTableDescriptor

public HTableDescriptorBuilder buildHTableDescriptor(org.apache.hadoop.hbase.HTableDescriptor tableDescriptorToCopy)

Specified by:

buildHTableDescriptor in class HBaseTableUtil

getHTableDescriptor

public org.apache.hadoop.hbase.HTableDescriptor getHTableDescriptor(org.apache.hadoop.hbase.client.HBaseAdmin admin,
                                                           TableId tableId)
                                                             throws IOException

Specified by:

getHTableDescriptor in class HBaseTableUtil

Throws:

IOException

hasNamespace

public boolean hasNamespace(org.apache.hadoop.hbase.client.HBaseAdmin admin,
                   String namespace)
                     throws IOException

Specified by:

hasNamespace in class HBaseTableUtil

Throws:

IOException

createNamespaceIfNotExists

public void createNamespaceIfNotExists(org.apache.hadoop.hbase.client.HBaseAdmin admin,
                              String namespace)
                                throws IOException

Specified by:

createNamespaceIfNotExists in class HBaseTableUtil

Throws:

IOException

deleteNamespaceIfExists

public void deleteNamespaceIfExists(org.apache.hadoop.hbase.client.HBaseAdmin admin,
                           String namespace)
                             throws IOException

Specified by:

deleteNamespaceIfExists in class HBaseTableUtil

Throws:

IOException

disableTable

public void disableTable(org.apache.hadoop.hbase.client.HBaseAdmin admin,
                TableId tableId)
                  throws IOException

Specified by:

disableTable in class HBaseTableUtil

Throws:

IOException

enableTable

public void enableTable(org.apache.hadoop.hbase.client.HBaseAdmin admin,
               TableId tableId)
                 throws IOException

Specified by:

enableTable in class HBaseTableUtil

Throws:

IOException

tableExists

public boolean tableExists(org.apache.hadoop.hbase.client.HBaseAdmin admin,
                  TableId tableId)
                    throws IOException

Specified by:

tableExists in class HBaseTableUtil

Throws:

IOException

deleteTable

public void deleteTable(org.apache.hadoop.hbase.client.HBaseAdmin admin,
               TableId tableId)
                 throws IOException

Specified by:

deleteTable in class HBaseTableUtil

Throws:

IOException

modifyTable

public void modifyTable(org.apache.hadoop.hbase.client.HBaseAdmin admin,
               org.apache.hadoop.hbase.HTableDescriptor tableDescriptor)
                 throws IOException

Specified by:

modifyTable in class HBaseTableUtil

Throws:

IOException

getTableRegions

public List<org.apache.hadoop.hbase.HRegionInfo> getTableRegions(org.apache.hadoop.hbase.client.HBaseAdmin admin,
                                                        TableId tableId)
                                                          throws IOException

Specified by:

getTableRegions in class HBaseTableUtil

Throws:

IOException

listTablesInNamespace

public List<TableId> listTablesInNamespace(org.apache.hadoop.hbase.client.HBaseAdmin admin,
                                  String namespaceId)
                                    throws IOException

Specified by:

listTablesInNamespace in class HBaseTableUtil

Throws:

IOException

listTables

public List<TableId> listTables(org.apache.hadoop.hbase.client.HBaseAdmin admin)
                         throws IOException

Specified by:

listTables in class HBaseTableUtil

Throws:

IOException

setCompression

public void setCompression(org.apache.hadoop.hbase.HColumnDescriptor columnDescriptor,
                  HBaseTableUtil.CompressionType type)

Specified by:

setCompression in class HBaseTableUtil

setBloomFilter

public void setBloomFilter(org.apache.hadoop.hbase.HColumnDescriptor columnDescriptor,
                  HBaseTableUtil.BloomType type)

Specified by:

setBloomFilter in class HBaseTableUtil

getCompression

public HBaseTableUtil.CompressionType getCompression(org.apache.hadoop.hbase.HColumnDescriptor columnDescriptor)

Specified by:

getCompression in class HBaseTableUtil

getBloomFilter

public HBaseTableUtil.BloomType getBloomFilter(org.apache.hadoop.hbase.HColumnDescriptor columnDescriptor)

Specified by:

getBloomFilter in class HBaseTableUtil

getTransactionDataJanitorClassForVersion

public Class<? extends org.apache.hadoop.hbase.Coprocessor> getTransactionDataJanitorClassForVersion()

Specified by:

getTransactionDataJanitorClassForVersion in class HBaseTableUtil

getQueueRegionObserverClassForVersion

public Class<? extends org.apache.hadoop.hbase.Coprocessor> getQueueRegionObserverClassForVersion()

Specified by:

getQueueRegionObserverClassForVersion in class HBaseTableUtil

getDequeueScanObserverClassForVersion

public Class<? extends org.apache.hadoop.hbase.Coprocessor> getDequeueScanObserverClassForVersion()

Specified by:

getDequeueScanObserverClassForVersion in class HBaseTableUtil

getIncrementHandlerClassForVersion

public Class<? extends org.apache.hadoop.hbase.Coprocessor> getIncrementHandlerClassForVersion()

Specified by:

getIncrementHandlerClassForVersion in class HBaseTableUtil

getHTableNameConverter

protected HTableNameConverter getHTableNameConverter()

Specified by:

getHTableNameConverter in class HBaseTableUtil