hbase数据查询如何范围扫描_行业观察_资讯中心

发布时间:2026-04-25 21:43:44

阅读量:2

在HBase中，你可以使用scan方法进行范围扫描

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

public class HBaseRangeScan {
    public static void main(String[] args) throws Exception {
        // 创建HBase连接
        Configuration conf = HBaseConfiguration.create();
        Connection connection = ConnectionFactory.createConnection(conf);
        Admin admin = connection.getAdmin();

        // 获取表
        TableName tableName = TableName.valueOf("your_table_name");
        Table table = connection.getTable(tableName);

        // 创建扫描器
        Scan scan = new Scan();

        // 设置起始行键
        byte[] startRow = Bytes.toBytes("start_row");
        scan.setStartRow(startRow);

        // 设置结束行键
        byte[] endRow = Bytes.toBytes("end_row");
        scan.setEndRow(endRow);

        // （可选）设置扫描条件，例如：设置扫描版本
        // scan.setVersion(1);

        // 执行范围扫描
        ResultScanner scanner = table.getScanner(scan);
        for (Result result : scanner) {
            System.out.println("Found row: " + result);
        }

        // 关闭资源
        scanner.close();
        table.close();
        admin.close();
        connection.close();
    }
}