hbaseでデータを追加するためにputをどのように使用するか。

1年 ago
陽, 向宇
1 minute

HBaseでは、データの追加にPutクラスを使用することができます。Putクラスはorg.apache.hadoop.hbase.clientパッケージに属するクラスで、挿入または更新するデータを表すために使用されます。

以下はPutクラスを使用してデータを追加する手順です。

  1. Putオブジェクトを作成し、行キーを構築関数のパラメーターとして渡します。行キーはデータの一意の識別子であり、HBaseテーブル内のデータの位置を特定するために使用されます。
  2. Put put = new Put(Bytes.toBytes(“row1”));
    put = new Put(Bytes.toBytes(“row1”));
  3. addColumn メソッドを使用して、挿入または更新する列ファミリ（column family）、列修飾子（column qualifier）および対応する値を追加します。
  4. put.addColumn(Bytes.toBytes(“cf1”), Bytes.toBytes(“col1”), Bytes.toBytes(“value1”));を追加します。
  5. 複数の列を追加する必要がある場合は、addColumnメソッドを繰り返し呼び出すことができます。
  6. put.addColumn(Bytes.toBytes(“cf1”), Bytes.toBytes(“col2”), Bytes.toBytes(“value2”));
    put.addColumn(Bytes.toBytes(“cf2”), Bytes.toBytes(“col3”), Bytes.toBytes(“value3”));
    → put.addColumn(Bytes.toBytes(“cf1”), Bytes.toBytes(“col2”), Bytes.toBytes(“value2”));
    put.addColumn(Bytes.toBytes(“cf2”), Bytes.toBytes(“col3”), Bytes.toBytes(“value3”));
  7. Tableのputメソッドを呼び出して、PutオブジェクトをHBaseテーブルに追加します。
  8. テーブルにデータを追加する。

以下是完整的代码示例：

import org.apache.hadoop.hbase.*;
import org.apache.hadoop.hbase.client.*;
import org.apache.hadoop.hbase.util.*;

public class HBaseExample {
    public static void main(String[] args) {
        try {
            // 创建 HBase 配置对象
            Configuration config = HBaseConfiguration.create();

            // 创建 HBase 连接对象
            Connection connection = ConnectionFactory.createConnection(config);

            // 获取 HBase 表对象
            TableName tableName = TableName.valueOf("mytable");
            Table table = connection.getTable(tableName);

            // 创建 Put 对象，并指定行键
            Put put = new Put(Bytes.toBytes("row1"));

            // 添加列族、列限定符和值
            put.addColumn(Bytes.toBytes("cf1"), Bytes.toBytes("col1"), Bytes.toBytes("value1"));
            put.addColumn(Bytes.toBytes("cf1"), Bytes.toBytes("col2"), Bytes.toBytes("value2"));

            // 将 Put 对象添加到表中
            table.put(put);

            // 关闭连接
            table.close();
            connection.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

上記のコードは参考のためであり、実際に使用する際は自身の環境や必要に応じて適切に修正する必要があります。

bannerAds