Hbase批处理在AsyncProcess.java中被阻塞

可以尝试使用以下代码示例解决该问题：

Configuration conf = HBaseConfiguration.create(); Connection connection = ConnectionFactory.createConnection(conf); // 构造table对象 TableName tableName = TableName.valueOf("table_name"); Table table = connection.getTable(tableName);

// 构造Batch为存储Put实例的List对象 List<Put> batch = new ArrayList<>(); Put put1 = new Put(Bytes.toBytes("row_key_1")); put1.addColumn(Bytes.toBytes("family"), Bytes.toBytes("qualifier"), Bytes.toBytes("value_1")); batch.add(put1); Put put2 = new Put(Bytes.toBytes("row_key_2")); put2.addColumn(Bytes.toBytes("family"), Bytes.toBytes("qualifier"), Bytes.toBytes("value_2")); batch.add(put2);

// 调用Table.put(List<Put>)方法插入数据 table.put(batch); table.close(); connection.close();

这段代码使用HBase的批处理API，构造了一个Put的List对象，并一次性插入了多条记录。这种方法比较高效，适合大量数据插入的场景。同时也避免了AsyncProcess.java中的阻塞问题。