在HBase中使用单行

Question

我正在通过Java API使用HBase来管理一个URL和参数列表，这些URL和参数等待一个带有多个线程的刮刀进行分析。程序还不断地向表中添加新行。

我需要连续地从表中读取一行并且只读取一行，然后原子地删除它（一行不能同时被两个线程读取），而不需要选择一行而不是另一行的条件。

Scan s = new Scan();
ss = t.getScanner(s);
for(Result r:ss){
  String ris=Bytes.toString(r.getRow())+Bytes.toString(r.getValue(Bytes.toBytes("TTL"),Bytes.toBytes("value")));
  //delete the retrieved row
  t.delete(new Delete(r.getRow()));
  ss.close();
  //return at the first iteration, after closing the Scanner
  return ris;
}

编辑：我忘了提到表有一个具有单个列的单个列族

Answer 1

你可以尝试使用带过滤器的扫描。 ，我认为PageFilter适合你的目的。