使用java，读取hbase2.0以上版本的数据，查询字段为id，其中的区间值为最小值为1，最大值为200，统计该区间的数，详细代码

**使用Java读取HBase2.0以上版本的数据**

### **概述**

本文将介绍如何使用Java读取HBase2.0以上版本的数据。我们将使用HBase的客户端API来实现这一点。

### **依赖**

首先，我们需要在pom.xml文件中添加以下依赖：

xml<dependency>
 <groupId>org.apache.hbase</groupId>
 <artifactId>hbase-client</artifactId>
 <version>2.0.1</version>
</dependency>

<dependency>
 <groupId>org.apache.hbase</groupId>
 <artifactId>hbase-common</artifactId>
 <version>2.0.1</version>
</dependency>

<dependency>
 <groupId>org.apache.hbase</groupId>
 <artifactId>hbase-protocol</artifactId>
 <version>2.0.1</version>
</dependency>

properties# HBase配置hbase.zookeeper.quorum=localhosthbase.master.port=16000

javaimport org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.client.Scan;
import org.apache.hadoop.hbase.filter.CompareFilter;
import org.apache.hadoop.hbase.filter.FilterList;
import org.apache.hadoop.hbase.filter.SingleColumnValueFilter;
import org.apache.hadoop.hbase.util.Bytes;

public class HBaseReader {

 public static void main(String[] args) throws Exception {
 // 创建HBase连接 HBaseConnection connection = new HBaseConnection();

 // 指定表名和列族 String tableName = "mytable";
 String familyName = "cf";

 // 指定查询条件 int minId =1;
 int maxId =200;

 // 创建Scan对象 Scan scan = new Scan(Bytes.toBytes(minId), Bytes.toBytes(maxId));

 // 添加过滤器 FilterList filterList = new FilterList();
 SingleColumnValueFilter filter = new SingleColumnValueFilter(Bytes.toBytes(familyName),
 Bytes.toBytes("id"), CompareFilter.CompareOp.GREATER_THAN_OR_EQUAL,
 Bytes.toBytes(minId));
 filterList.addFilter(filter);
 scan.setFilter(filterList);

 // 执行查询 Result result = connection.get(tableName, familyName, scan);

 // 解析结果 while (result != null) {
 byte[] rowKey = result.getRow();
 System.out.println("Row Key: " + Bytes.toString(rowKey));

 // 获取列值 byte[] value = result.getValue(Bytes.toBytes(familyName), Bytes.toBytes("id"));
 if (value != null) {
 int id = Integer.parseInt(Bytes.toString(value));
 System.out.println("ID: " + id);
 }

 result = connection.nextResult();
 }
 }
}

java// 统计区间值int count =0;
while (result != null) {
 byte[] rowKey = result.getRow();
 System.out.println("Row Key: " + Bytes.toString(rowKey));

 // 获取列值 byte[] value = result.getValue(Bytes.toBytes(familyName), Bytes.toBytes("id"));
 if (value != null) {
 int id = Integer.parseInt(Bytes.toString(value));
 if (id >= minId && id <= maxId) {
 count++;
 }
 }

 result = connection.nextResult();
}

System.out.println("Count: " + count);