hadoop - 带偏移量的 Hbase 扫描

Question

有没有办法扫描 HBase 表，例如，获取前 100 个结果，然后再得到下一个 100 等等......就像我们在 SQL 中做的一样使用 LIMIT 和 OFFSET？我的行键是 uuid

Answer 1

您可以通过多种方式进行。最简单的一个是页面过滤器。下面是来自 HBase: The Definitive Guide 的代码示例，第 150 页。

private static final byte[] POSTFIX = new byte[] { 0x00 };Filter filter = new PageFilter(15);int totalRows = 0; byte[] lastRow = null; while (true) {  Scan scan = new Scan();   scan.setFilter(filter);   if (lastRow != null) {    byte[] startRow = Bytes.add(lastRow, POSTFIX);     System.out.println("start row: " + Bytes.toStringBinary(startRow));     scan.setStartRow(startRow);  }
  ResultScanner scanner = table.getScanner(scan);   int localRows = 0;  
  Result result;  
  while ((result = scanner.next()) != null) {     System.out.println(localRows++ + ": " + result);      totalRows++;
     lastRow = result.getRow();  }
  scanner.close();
  if (localRows == 0) break;}
System.out.println("total rows: " + totalRows);

或者您可以设置扫描时捕捉到您想要的限制，然后将起始行更改为每次获取的上一次扫描的最后一行 + 1。