hbase建表语句样例-CFANZ编程社区

HBase建表语句样例及示例代码

什么是HBase？

HBase是Apache Hadoop生态系统中的一部分，是一个高可靠性、高性能、分布式的列式存储数据库。它主要用于存储大规模结构化和半结构化数据，可以提供实时读写能力，并且能够在集群中线性扩展。

HBase表结构

在HBase中，数据被组织成表。每个表由一个表名唯一标识，表中的数据按照行和列族的形式进行存储。行是通过行键（Row Key）进行唯一标识的，列族（Column Family）是一组相关的列，每个列族可以包含多个列限定符（Column Qualifier）。

HBase建表语句样例

以下是一个建表语句的样例，我们将通过这个样例来详细介绍建表语句的不同部分：

create 'student', 'info', 'marks'

在这个建表语句中，我们创建了一个名为student的表，包含两个列族：info和marks。

student：表名，用于唯一标识一个表。在这个例子中，我们创建了一个名为student的表。
info和marks：列族，用于对表中的数据进行逻辑分组。在这个例子中，我们创建了两个列族：info和marks。

HBase建表示例代码

现在我们来看一个示例代码，通过Java API来创建HBase表：

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.HColumnDescriptor;
import org.apache.hadoop.hbase.HTableDescriptor;
import org.apache.hadoop.hbase.client.Admin;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.ConnectionFactory;
import org.apache.hadoop.hbase.util.Bytes;

public class HBaseTableCreationExample {
    public static void main(String[] args) throws Exception {
        // 创建HBase配置对象
        Configuration config = HBaseConfiguration.create();

        // 创建HBase连接对象
        Connection connection = ConnectionFactory.createConnection(config);

        // 创建HBase管理员对象
        Admin admin = connection.getAdmin();

        // 创建表描述符对象
        HTableDescriptor tableDescriptor = new HTableDescriptor(TableName.valueOf("student"));

        // 创建列族描述符对象
        HColumnDescriptor infoColumnFamily = new HColumnDescriptor(Bytes.toBytes("info"));
        HColumnDescriptor marksColumnFamily = new HColumnDescriptor(Bytes.toBytes("marks"));

        // 将列族描述符添加到表描述符中
        tableDescriptor.addFamily(infoColumnFamily);
        tableDescriptor.addFamily(marksColumnFamily);

        // 创建表
        admin.createTable(tableDescriptor);

        // 关闭连接
        admin.close();
        connection.close();
    }
}

在这个示例代码中，我们使用HBase Java API来创建名为student的表，并向表中添加了两个列族：info和marks。

首先，我们创建了一个HBase配置对象并通过HBaseConfiguration类的create()方法进行初始化。然后，我们使用ConnectionFactory类的createConnection()方法创建了HBase连接对象。接下来，我们通过连接对象得到了HBase管理员对象。

然后，我们创建了一个表描述符对象，用于描述表的属性。我们使用HTableDescriptor类的构造函数创建了一个名为student的表描述符对象。

接着，我们创建了两个列族描述符对象，分别对应info和marks列族。我们使用HColumnDescriptor类的构造函数创建了这两个列族描述符对象，并将它们添加到表描述符对象中。

最后，我们使用管理员对象的createTable()方法创建了表，并关闭了连接。