hbase 批量操作

### HBase 批量操作概述

HBase支持多种批量操作，这些功能允许用户高效地管理大量数据。通过使用`batch()`方法，可以执行多个不同类型的行级操作（如插入、更新和删除），并将其作为一个原子事务提交给数据库[^1]。

对于批量插入、更新和删除的具体实现方式如下：

#### 批量插入

当需要向HBase表中添加多条记录时，可以通过构建一系列的`Put`对象并将它们加入到一个列表里来完成这一过程。之后调用`Table.batch()`函数即可一次性将所有的更改应用至目标表格内。

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

List<Put> puts = new ArrayList<>();
for (int i = 0; i < count; ++i) {
    Put put = new Put(Bytes.toBytes("row-" + i));
    put.addColumn(Bytes.toBytes("cf"), Bytes.toBytes("qualifier"), Bytes.toBytes("value"));
    puts.add(put);
}

Object[] results;
try {
    results = table.batch((List<? extends Row>) puts);
} catch (Exception e) {
    throw new RuntimeException(e.getMessage());
}

此代码片段展示了如何利用Java API来进行大批量的数据加载工作[^2]。

#### 批量更新

如果要修改已存在的某些字段值，则应该采用类似的策略——即先准备一批待处理的对象集合，在这里是`Mutate`类型下的子类实例；随后再把这些变更请求传递给`table.batch()`接口去统一处理。

需要注意的是，“更新”实际上是在原有基础上追加新版本列族成员的行为，而非覆盖旧有内容。因此每次改动都会形成一个新的时间戳副本存放在底层存储引擎之中[^3]。

#### 批量删除

针对想要移除特定范围内的键值对的情况，同样适用上述提到过的模式：建立一组代表各个需被清除实体的`Delete`指令集，并经由相同的途径发送出去等待响应确认消息返回为止。

下面给出了一段简单的例子用于说明怎样安全有效地实施此类动作：

// 获取指定名称空间中的某张表
Table table = conn.getTable(tableName);

// 定义受影响的目标行标识符数组
byte[][] rowsToDelete = { ... };

// 构建对应的Delete命令序列
List<Delete> deletes = Arrays.stream(rowsToDelete).map(
        r -> new Delete(r)).collect(Collectors.toList());

// 提交批处理任务
try {
    table.delete(deletes);
} catch (IOException ex) {
    logger.error(ex.toString(), ex);
}
finally{
    try{if(table!=null){table.close();}}catch(IOException io){}
}

这段脚本实现了对选定范围内所有符合条件项的一次性消除操作[^4]。