0

我有一个带有示例记录的 hbase 表，如下所示：

  03af639717ae10eb743253433147e133                 column=u:a, timestamp=1434300763147, value=apple
  10f3d7f8fe8f25d5bdf52343a2601227                 column=u:a, timestamp=1434300763148, value=mapple
  20164b1aff21bc14e94623423a9d645d                 column=u:a, timestamp=1534300763142, value=papple
  44d1cb38271362d20911a723410b2c67                 column=u:a, timestamp=1634300763141, value=scapple

当我试图根据时间戳提取行值时，我迷路了。我正在使用spring data hadoop. 我只能使用以下代码获取所有记录：

 private static final byte[] CF_INFO = Bytes.toBytes("u");
 private static final byte[] baseUrl = Bytes.toBytes("a");

 List<Model> allNewsList
            = hbaseTemplate.find(tableName, columnFamily, new RowMapper<News>()
            {
                @Override
                public Model mapRow(Result result, int rowNum)
                throws Exception 
                {
                    String dateString = TextUtils.getTimeStampInLong(result.toString());
                    String rowKey = Bytes.toString(result.getRow());
                    return new Model(                                
                        rowKey,
                        Bytes.toString(result.getValue(CF_INFO, col_a)
                    );
                }
            });

如何应用过滤器以便能够在 timestamp 内获取记录[1434300763147,1534300763142]。

4

2 回答 2

1

希望有一天这会对某人有所帮助。

final org.apache.hadoop.hbase.client.Scan scan = new Scan();
scan.setTimeRange(1434300763147,1534300763142);
final List<Model> yourObjects = hbaseTemplate.find(tableName, scan, mapper);

另外，值得一提的是，timerange 的最大值是独占的，因此如果您希望返回具有该时间戳的记录，请确保将 timerange 的最大值增加 1。

于 2018-07-07T06:30:09.353 回答
0

使用 Hbase 客户端的 Scanner 对象解决了该问题。

于 2015-08-13T18:20:14.720 回答