TOP

hbase中根据Rowkey后缀进行查询
2018-11-28 17:37:41 】 浏览:421
Tags:hbase 根据 Rowkey 后缀 进行 查询

版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/yuyinghua0302/article/details/78612668

假如hbase表设计时,Rowkey设计为“time+uid”(这里不考虑hbase的Rowkey设计合理性,只是简单说明)。现在有一个需求,筛选出某一uid在一个时间段[time1,time2)的值,该怎么办呢?

如果是在命令行中进行查询,可以结合startrow,endrow,filter,(column),具体如下所示:

scan ‘tablename’,
{STARTROW=>’time1+uid’,ENDROW=>’time2+uid’,FILTER=>”RowFilter(=,’regexstring:.*uid’)”}

如果是在代码中进行查询,

Configuration config = new Configuration();
config.set("hbase.zookeeper.quorum", "10.1.1.1");//需根据hbase配置进行设置
HBaseConfiguration hbaseConfig = new HBaseConfiguration(config);

Scan scan = new Scan();
scan.setStartRow(Bytes.toBytes(time1+uid));
scan.setStopRow(Bytes.toBytes(time2+uid));
Filter filter = new RowFilter(CompareFilter.CompareOp.EQUAL,new RegexStringComparator(".*"+uid));
scan.setFilter(filter);

ResultScanner rs = null;
HTable table = new HTable(hbaseConfig, Bytes.toBytes(tableName));
String rowkey = null;
rs = table.getScanner(scan);
for (Result r : rs) {
    for (KeyValue kv : r.list()) {
        rowkey = Bytes.toString(kv.getRow());
        System.out.println(rowkey);
    }   
}

hbase中根据Rowkey后缀进行查询 https://www.cppentry.com/bencandy.php?fid=118&id=187012

】【打印繁体】【投稿】【收藏】 【推荐】【举报】【评论】 【关闭】 【返回顶部
上一篇Hbase shell 常用命令(1) 下一篇MAC上配置haddop+Hbase开发环境