加载中…
个人资料
  • 博客等级:
  • 博客积分:
  • 博客访问:
  • 关注人气:
  • 获赠金笔:0支
  • 赠出金笔:0支
  • 荣誉徽章:
正文 字体大小:

hbase row key 的前缀相同查询实例

(2014-08-27 11:09:55)
分类: HBase
问题导读:                          
1.如何查询row key前缀相同的数据?
2.hbase查询实现方式有几种?
3.通过Java api,如何实现过滤前缀?

http://www.aboutyun.com/static/image/hrline/4.gifrow key 的前缀相同查询实例" />


如果你在hbase表中存在一些特征相同的记录,实际上就可以通过设置Filter的方式进行检索过滤。

比如这个特征是前缀相同。

           
ROW
Jerry  
Jerry1
Jerry2


可以发现这三条记录都是以Jerry开头的row key.

那么我们如何检索呢。很简单。

如果是在hbase shell中

scan ‘scores’, {FILTER => org.apache.hadoop.hbase.filter.PrefixFilter.new(org.apache.hadoop.hbase.util.Bytes.toBytes(‘Jerry’))}

如果是java 客户端

  1. public void scaneByPrefixFilter(String tablename, String rowPrifix) {
  2.    try {
  3.        HTable table = new HTable(conf, tablename);
  4.        Scan s = new Scan();
  5.        s.setFilter(new PrefixFilter(rowPrifix.getBytes()));
  6.        ResultScanner rs = table.getScanner(s);
  7.        for (Result r : rs) {
  8.           KeyValue[] kv = r.raw();
  9.           for (int i = 0; i < kv.length; i++) {
  10.               System.out.print(new String(kv[i].getRow()) + "  ");
  11.               System.out.print(new String(kv[i].getFamily()) + ":");
  12.               System.out.print(new String(kv[i].getQualifier()) + "  ");
  13.               System.out.print(kv[i].getTimestamp() + "  ");
  14.               System.out.println(new String(kv[i].getValue()));
  15.           }
  16.       }
  17.    } catch (IOException e) {
  18.          e.printStackTrace();
  19.    }
  20. }
复制代码

0

阅读 收藏 喜欢 打印举报/Report
  

新浪BLOG意见反馈留言板 欢迎批评指正

新浪简介 | About Sina | 广告服务 | 联系我们 | 招聘信息 | 网站律师 | SINA English | 产品答疑

新浪公司 版权所有