面试题：Hbase中如何通过Java API实现简单的批量插入数据操作

Question

请阐述在Hbase中，使用Java API进行批量插入数据的基本步骤，假设已有一个Hbase表'test_table'，列族为'cf'，需要批量插入100条数据，每行数据的rowkey为自增的数字，列限定符为'col1'，值为'value_'加上rowkey，请写出关键代码片段。

Answer 1

1. 导入必要的包：

   import org.apache.hadoop.conf.Configuration;
   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.Put;
   import org.apache.hadoop.hbase.client.Table;
   import org.apache.hadoop.hbase.util.Bytes;
   

2. 创建HBase配置和连接：

   Configuration config = HBaseConfiguration.create();
   try (Connection connection = ConnectionFactory.createConnection(config);
        Table table = connection.getTable(TableName.valueOf("test_table"))) {
   

3. 构建批量插入数据：

   for (int i = 0; i < 100; i++) {
       Put put = new Put(Bytes.toBytes(String.valueOf(i)));
       put.addColumn(Bytes.toBytes("cf"), Bytes.toBytes("col1"), Bytes.toBytes("value_" + i));
       table.put(put);
   }
   

4. 关闭连接：

   } catch (Exception e) {
       e.printStackTrace();
   }
   

完整代码如下：

import org.apache.hadoop.conf.Configuration;
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.Put;
import org.apache.hadoop.hbase.client.Table;
import org.apache.hadoop.hbase.util.Bytes;

public class HBaseBulkInsert {
    public static void main(String[] args) {
        Configuration config = HBaseConfiguration.create();
        try (Connection connection = ConnectionFactory.createConnection(config);
             Table table = connection.getTable(TableName.valueOf("test_table"))) {
            for (int i = 0; i < 100; i++) {
                Put put = new Put(Bytes.toBytes(String.valueOf(i)));
                put.addColumn(Bytes.toBytes("cf"), Bytes.toBytes("col1"), Bytes.toBytes("value_" + i));
                table.put(put);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}