hbase批量插入json数据liuxe

你可以使用 HBase 的 Java API 来实现批量插入 JSON 数据。下面是一个示例代码：

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.client.*;
import org.apache.hadoop.hbase.util.Bytes;
import org.json.JSONArray;
import org.json.JSONObject;

import java.io.IOException;

public class HBaseJsonBulkInsert {
    private static final String TABLE_NAME = "your_table_name";
    private static final String COLUMN_FAMILY = "your_column_family";
    private static final String COLUMN_QUALIFIER = "your_column_qualifier";

    public static void main(String[] args) {
        Configuration conf = HBaseConfiguration.create();
        try (Connection connection = ConnectionFactory.createConnection(conf);
             Table table = connection.getTable(TableName.valueOf(TABLE_NAME))) {

            JSONArray jsonArray = new JSONArray("your_json_array"); // 将你的 JSON 数据转换为 JSONArray 对象

            Put[] puts = new Put[jsonArray.length()];
            for (int i = 0; i < jsonArray.length(); i++) {
                JSONObject jsonObject = jsonArray.getJSONObject(i);
                String rowKey = jsonObject.getString("id"); // 假设你的 JSON 数据中有一个字段名为 id，用作行键
                String value = jsonObject.toString(); // 将整个 JSON 对象转换为字符串，作为值

                Put put = new Put(Bytes.toBytes(rowKey));
                put.addColumn(Bytes.toBytes(COLUMN_FAMILY), Bytes.toBytes(COLUMN_QUALIFIER), Bytes.toBytes(value));
                puts[i] = put;
            }

            table.put(puts); // 批量插入数据

            System.out.println("Data inserted successfully.");
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

请将 `your_table_name`、`your_column_family`、`your_column_qualifier` 替换为你实际的表名、列族名和列限定符名。将 `your_json_array` 替换为你的 JSON 数组变量名或直接写入 JSON 数组的字符串。

这个示例使用 HBase 的 Java API 将 JSON 数组中的每个对象转换为适当的 HBase Put 对象，并使用 `table.put()` 方法进行批量插入。