hadoop - rowkey 不完全已知时的 HBase 查询

Question

我打算在 HBase 中存储流式天气数据。我的行键是:[5 个字母的城市代码][时间戳] 其中时间戳是 [日期][HH:mm:ss.SSS 中的时间]我只有一栏叫做“温度”。所以样本数据看起来像:

NEWYO20131121080932123 32.4  
NEWYO20131121081034342 34.6  
NEWYO20131121081156424 31.8  
NEWYO20131121081223532 24.9  
SINGA20131121091142563 23.1  
SANFR20131121091214763 22.1 

我想查询数据以返回纽约 11 月 21 日 8:11 到 8:13 之间的温度值(应返回第 3 行和第 4 行)

如何使用 Java API 为此编写查询。

我遇到了 Scan(byte[] startRow, byte[] stopRow)，但我不认为我可以使用它，因为我在检索数据时不知道确切的行键(因为key末尾有秒和毫秒)

(是否可以对行键使用正则表达式？)

Answer 1

您可以使用 RowFilter。以下代码将有所帮助

Filter filter2 = new RowFilter(CompareFilter.CompareOp.EQUAL,
new RegexStringComparator("regex"));
scan.setFilter(filter2);
ResultScanner scanner2 = table.getScanner(scan);
for (Result res : scanner2) {
   System.out.println(res);
}