Sqoop 操作 HBase 第1关：Sqoop 在HBase中导入

Sqoop 是一个用于在 Hadoop 生态系统中导入和导出数据的工具。在本关中，我们将学习如何使用 Sqoop 将数据从关系型数据库导入到 HBase 中。

首先，我们需要确保已经在 Hadoop 集群中安装了 Sqoop 和 HBase。然后，我们需要创建一个目标表来存储从关系型数据库中导入的数据。

在 HBase 中创建表：

create 'employees', 'personal', 'professional'

现在，我们可以使用 Sqoop 将数据从关系型数据库中导入到 HBase 中。假设我们要从 MySQL 数据库中导入一个名为 employees 的表，该表包含以下列和数据：

| id | name | age | salary |
|----|------|-----|--------|
| 1 | John | 25 | 50000 |
| 2 | Mary | 30 | 60000 |
| 3 | Jack | 40 | 70000 |

我们可以使用以下命令将该表导入到 HBase 中：

sqoop import --connect jdbc:mysql://localhost/employees --username root --password password --table employees --hbase-table employees --column-family personal --hbase-row-key id --hbase-create-table

该命令将从 MySQL 数据库中选择所有列，并将它们插入到 HBase 表中。我们指定了 HBase 表的名称和列族名称，以及用于 HBase 行键的列。

如果 HBase 表不存在，Sqoop 将自动创建它。我们还指定了一个选项 hbase-create-table，以确保表已经存在，如果表不存在则会创建。如果不使用此选项，则需要手动创建 HBase 表。

我们可以使用以下命令查看导入的数据：

hbase shell
scan 'employees'

输出应如下所示：

ROW     COLUMN+CELL
 1      column=personal:age, timestamp=1576289403403, value=25
 1      column=personal:name, timestamp=1576289403403, value=John
 1      column=personal:salary, timestamp=1576289403403, value=50000
 2      column=personal:age, timestamp=1576289403403, value=30
 2      column=personal:name, timestamp=1576289403403, value=Mary
 2      column=personal:salary, timestamp=1576289403403, value=60000
 3      column=personal:age, timestamp=1576289403403, value=40
 3      column=personal:name, timestamp=1576289403403, value=Jack
 3      column=personal:salary, timestamp=1576289403403, value=70000

我们可以看到，导入的数据已经存储在 HBase 表中。现在，我们可以在 Hadoop 生态系统中使用这些数据进行分析和处理。