HBase - 创建表

使用 HBase Shell 创建表

您可以使用 create 命令创建表，在这里您必须指定表名和列系列名称。在 HBase shell 中创建表的语法如下所示。

create '<table name>','<column family>'

示例

下面给出了名为 emp 的表的示例架构。它有两个列系列："personal data(个人数据)"和"professional data(专业数据)"。

您可以在 HBase shell 中创建此表，如下所示。

hbase(main):002:0> create 'emp', 'personal data', 'professional data'

它将为您提供以下输出。

0 row(s) in 1.1300 seconds
=> Hbase::Table - emp

验证

您可以使用 list 命令验证表是否已创建，如下所示。在这里您可以观察创建的 emp 表。

hbase(main):002:0> list
TABLE 
emp
2 row(s) in 0.0340 seconds

使用 Java API 创建表

您可以使用 HBaseAdmin 类的 createTable() 方法在 HBase 中创建表。此类属于 org.apache.hadoop.hbase.client 包。下面给出了使用 Java API 在 HBase 中创建表的步骤。

步骤 1：实例化 HBaseAdmin

此类需要 Configuration 对象作为参数，因此首先实例化 Configuration 类并将此实例传递给 HBaseAdmin。

Configuration conf = HBaseConfiguration.create();
HBaseAdmin admin = new HBaseAdmin(conf);

步骤2：创建TableDescriptor

HTableDescriptor是属于org.apache.hadoop.hbase类的一个类。该类就像是表名和列族的容器。

//创建表描述符
HTableDescriptor table = new HTableDescriptor(toBytes("表名"));

//创建列族描述符
HColumnDescriptor family = new HColumnDescriptor(toBytes("列族"));

//将列族添加到HTable
table.addFamily(family);

步骤3：通过Admin执行

使用HBaseAdmin类的createTable()方法，可以在Admin模式下执行创建的表。

admin.createTable(table);

下面给出了通过admin创建表的完整程序。

import java.io.IOException;

import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.HColumnDescriptor;
import org.apache.hadoop.hbase.HTableDescriptor;
import org.apache.hadoop.hbase.client.HBaseAdmin;
import org.apache.hadoop.hbase.TableName;

import org.apache.hadoop.conf.Configuration;

public class CreateTable {
      
   public static void main(String[] args) throws IOException {

        // 实例化配置类
        Configuration con = HBaseConfiguration.create();
        
        // 实例化 HbaseAdmin 类
        HBaseAdmin admin = new HBaseAdmin(con);
        
        // 实例化表描述符类
        HTableDescriptor tableDescriptor = new
        HTableDescriptor(TableName.valueOf("emp"));
        
        // 向表描述符添加列族
        tableDescriptor.addFamily(new HColumnDescriptor("personal"));
        tableDescriptor.addFamily(new HColumnDescriptor("professional"));
        
        // 通过 admin 执行表
        admin.createTable(tableDescriptor);
        System.out.println(" 表已创建 ");
   }
}

编译并执行上述程序，如下所示。

$javac CreateTable.java
$java CreateTable

输出应如下所示：

Table created