hbaseで特定のカラムの値を照会する方法

2年 ago
芽依, 雨夜
2 minutes

HBaseなどのシステムでは、Scan操作とGet操作のどちらかを使用して、特定の列の値を問い合わせることができます。

スキャンの操作使用

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.*;
import org.apache.hadoop.hbase.client.*;
import org.apache.hadoop.hbase.util.Bytes;

public class HBaseQuery {
    public static void main(String[] args) throws Exception {
        Configuration config = HBaseConfiguration.create();
        Connection connection = ConnectionFactory.createConnection(config);
        TableName tableName = TableName.valueOf("your_table_name");
        Table table = connection.getTable(tableName);

        Scan scan = new Scan();
        scan.addColumn(Bytes.toBytes("your_column_family"), Bytes.toBytes("your_column"));

        ResultScanner scanner = table.getScanner(scan);
        for (Result result : scanner) {
            byte[] value = result.getValue(Bytes.toBytes("your_column_family"), Bytes.toBytes("your_column"));
            String valueString = Bytes.toString(value);
            System.out.println("Value: " + valueString);
        }
        
        scanner.close();
        table.close();
        connection.close();
    }
}

Getリクエストを送信します。

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.*;
import org.apache.hadoop.hbase.client.*;
import org.apache.hadoop.hbase.util.Bytes;

public class HBaseQuery {
    public static void main(String[] args) throws Exception {
        Configuration config = HBaseConfiguration.create();
        Connection connection = ConnectionFactory.createConnection(config);
        TableName tableName = TableName.valueOf("your_table_name");
        Table table = connection.getTable(tableName);

        Get get = new Get(Bytes.toBytes("your_row_key"));
        get.addColumn(Bytes.toBytes("your_column_family"), Bytes.toBytes("your_column"));

        Result result = table.get(get);
        byte[] value = result.getValue(Bytes.toBytes("your_column_family"), Bytes.toBytes("your_column"));
        String valueString = Bytes.toString(value);
        System.out.println("Value: " + valueString);

        table.close();
        connection.close();
    }
}

上記のコードではyour_table_name, your_column_family, your_column, your_row_keyを、実際のテーブル名、列族名、カラム名、行キーに書き換える必要があります。

bannerAds