检查表是否存在

Question

检查 Hbase 表是否存在的最快方法是什么？查看此 API：

http://hbase.apache。 org/devapidocs/org/apache/hadoop/hbase/client/HBaseAdmin.html 其中哪一个最快：

1. tableExists
2. isTableEnabled
3. isTableAvailable
4. listTables

使用#4，您可以获得所有表的列表，并对其进行迭代，并比较这些表之一是否与您的表名称匹配。

或者还有另一种更聪明的方法？

Answer 1

这是我的示例代码。 (scala)

import org.apache.hadoop.hbase.HBaseConfiguration

var TableName = "sample"
val conf = HBaseConfiguration.create()
var hbaseAdmin = new HBaseAdmin(conf)
if (!hbaseAdmin.tableExists(TableName)) {
  println(TableName + " Does Not Exist")
}

这里，你只需要使用“tableExists”来检查这个TableName是否存在。

Answer 2

  HBaseAdmin hba = new HBaseAdmin(hbaseTemplate.getConfiguration());
    if (hba.tableExists(tableName) == false) {

        HTableDescriptor tableDescriptor = new HTableDescriptor(tableName);
        HColumnDescriptor columnDescriptor = new HColumnDescriptor(columnFamilyProfile);
        tableDescriptor.addFamily(columnDescriptor);

        hba.createTable(tableDescriptor);
    }

Answer 3

使用 HBaseAdmin.tableExists 只需大约 500ms 即可检查表是否存在。我们的集群中只有两个节点，因此它可能取决于集群的大小，但它看起来并不是不合理的慢。

Answer 4

您可以尝试打开 HTable 到表，（我认为）如果表不存在，它会抛出异常/错误（尚未工作，因此无法进行快速测试）。

这并不是 100% 有效，只是一个突发的想法。 :)

Answer 5

每次启动应用程序时，我都必须检查表是否存在。我已经在配置类中使用 Spring Boot 做了这个

这是代码，希望它有所帮助。

@Configuration
public class CustomHbaseConfiguration {

@Bean
public Connection hbaseConnection() throws IOException {
    // Create connection
    final org.apache.hadoop.conf.Configuration configuration = HBaseConfiguration.create();

    // Validate that Hbase is available
    HBaseAdmin.available(configuration);

    // return the hbaseConnection Bean
    return ConnectionFactory.createConnection(configuration);
}



@PostConstruct
public void hbaseTableLogic() throws IOException {

    // With the hbaseConnection bean, get the HbaseAdmin instance
    Admin admin = hbaseConnection().getAdmin();

    // The name of my table
    TableName YOUR_TABLE_NAME_HERE = TableName.valueOf("PUT_YOUR_TABLE_NAME_HERE");

    // Check if the table already exists ? else : create table and colum family
    if (!admin.tableExists(YOUR_TABLE_NAME_HERE)) {
        HTableDescriptor hTableDescriptor = new HTableDescriptor(YOUR_TABLE_NAME_HERE);
        hTableDescriptor.addFamily(new HColumnDescriptor("PUT_YOUR_COLUM_FAMILY_HERE"));
        admin.createTable(hTableDescriptor);
    }
}
}