Java hbase 表根据时间戳范围进行查询

在Java中，可以使用HBase API进行表根据时间戳范围进行查询。下面是一个简单的示例代码：

import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.Cell;
import org.apache.hadoop.hbase.CellUtil;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.ConnectionFactory;
import org.apache.hadoop.hbase.client.Get;
import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.client.ResultScanner;
import org.apache.hadoop.hbase.client.Scan;
import org.apache.hadoop.hbase.filter.FilterList;
import org.apache.hadoop.hbase.filter.SingleColumnValueFilter;
import org.apache.hadoop.hbase.filter.TimestampsFilter;
import org.apache.hadoop.hbase.util.Bytes;

public class HBaseQueryExample {

  public static void main(String[] args) throws IOException {
    Configuration conf = HBaseConfiguration.create();
    Connection conn = ConnectionFactory.createConnection(conf);
    TableName tableName = TableName.valueOf("table_name");
    Scan scan = new Scan();
    long startTime = System.currentTimeMillis() - 24 * 60 * 60 * 1000; // start time is 24 hours ago
    long endTime = System.currentTimeMillis(); // end time is current time
    List<Long> timestamps = new ArrayList<>();
    timestamps.add(startTime);
    timestamps.add(endTime);
    TimestampsFilter filter = new TimestampsFilter(timestamps);
    SingleColumnValueFilter columnFilter = new SingleColumnValueFilter(Bytes.toBytes("column_family"),
        Bytes.toBytes("column_qualifier"), CompareOperator.EQUAL, Bytes.toBytes("column_value"));
    FilterList filterList = new FilterList(FilterList.Operator.MUST_PASS_ALL);
    filterList.addFilter(filter);
    filterList.addFilter(columnFilter);
    scan.setFilter(filterList);
    ResultScanner scanner = conn.getTable(tableName).getScanner(scan);
    for (Result result : scanner) {
      for (Cell cell : result.listCells()) {
        byte[] valueBytes = CellUtil.cloneValue(cell);
        String value = Bytes.toString(valueBytes);
        System.out.println("Value: " + value);
      }
    }
    scanner.close();
    conn.close();
  }
}

在上面的代码中，我们首先创建了一个HBase连接和一个表名。然后，我们使用Scan对象创建一个查询，并设置起始时间和结束时间。接下来，我们使用TimestampsFilter和SingleColumnValueFilter创建一个过滤器列表FilterList，以仅返回指定时间范围内的包含指定列的行。最后，我们使用ResultScanner遍历结果并打印每个包含指定列的单元格的值。