使用Java API验证表的存在
您可以使用HBaseAdmin类的tableExists()方法来验证HBase中是否存在表。请按照以下步骤验证HBase中是否存在表。
第1步
// Instantiating configuration class
Configuration config = HBaseConfiguration.create();
Connection connection = ConnectionFactory.createConnection(config);
// Instantiating Admin class
Admin admin = null;
admin = connection.getAdmin();
第2步
使用tableExists()方法验证表是否存在。
下面给出了使用Java API测试HBase中表是否存在的Java程序。
import java.io.IOException;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.ConnectionFactory;
import org.apache.hadoop.hbase.client.Admin;
import org.apache.hadoop.conf.Configuration;
@SuppressWarnings("deprecation")
public class TableExists{
public static void main(String args[])throws IOException{
try {
// Instantiating configuration class
Configuration config = HBaseConfiguration.create();
Connection connection = ConnectionFactory.createConnection(config);
// Instantiating Admin class
Admin admin = null;
admin = connection.getAdmin();
boolean bool = admin.tableExists(TableName.valueOf("emp"));
System.out.println(bool);
} catch (Exception e) {
System.out.println(e.getMessage());
}
}
}
编译并执行上述程序,如下所示。
$javac TableExists.java
$java TableExists
以下应该是输出: