Hbase条件筛选

需求来自于,模糊查找当天的所有记录,并查找对应列的记录数

public static void main(String[] args) throws Exception{
    //创建HBase连接
    Configuration conf = HBaseConfiguration.create();
    //设定需要查询的表
    HTable table = new HTable(conf,"EVENT_LOG_LBS_HIS");
    Scan scan = new Scan();
    //设定模糊时间戳
    String startStr = "-20160530";
    //使用Hbase内置过滤器
     scan.setFilter(findCount(startStr));
  
    ResultScanner rowscan = table.getScanner(scan);
    int i = 1;
    //遍历结果
    for(Result rs : rowscan){
        System.out.println("第" + i + "条: rowkey= " + Bytes.toString(rs.getRow()));
    i++;
    //根据结果行中某一列的值,进行条件筛选
    String aaa = Bytes.toString(rs.getValue("f1".getBytes(),"LS_channel_type".getBytes()));
    if(aaa.equals("2"){
        System.out.println(Bytes.toString(rs.getRow()));
    }
    }

  public static FilterList findCount(String startstr){
      Filter filter = new RowFilter(CompareFilter.CompareOp.GREATER_OR_EQUAL,new RegexStringComparator(startstr));
  return filter;  
}

 其实可以都写成内置过滤器,不过HBase还没有深入学习,暂时先这样写啦~

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏码农分享

LinqToExcel.Extend 源码分析

展开目录结构,我们能够更加请详细的分析出每个目录所完成的功能模块。 这里主要讲解工具集中最重要的一个模块Validate

16440
来自专栏数据结构与算法

BZOJ1269: [AHOI2006]文本编辑器editor

Descriptio 这些日子,可可不和卡卡一起玩了,原来可可正废寝忘食的想做一个简单而高效的文本编辑器。你能帮助他吗? 为了明确任务目标,可可对“文本编辑器...

29470
来自专栏一名合格java开发的自我修养

Storm的BaseBasicBolt源码解析ack机制

我们在学习ack机制的时候,我们知道Storm的Bolt有BaseBasicBolt和BaseRichBolt。 在BaseBasicBolt中,BasicOu...

10210
来自专栏xingoo, 一个梦想做发明家的程序员

【设计模式】—— 桥接模式Bridge

  模式意图   这个模式使用的并不多,但是思想确实很普遍。就是要分离抽象部分与实现部分。   实现弱关联,即在运行时才产生依赖关系。   降低代码之间的耦合...

19570
来自专栏大内老A

[ASP.NET MVC]通过对HtmlHelper扩展简化“列表控件”的绑定

在众多表单元素中,有一类<select>元素用于绑定一组预定义列表。传统的ASP.NET Web Form中,它对应着一组重要的控件类型,即ListContro...

20650
来自专栏Java成神之路

Java微信开发_Exception_01_The type org.xmlpull.v1.XmlPullParser cannot be resolved. It is indirectly ref

这个异常是在做微信开发时出现的,在引入了XStream的jar包之后,还是出现了如下错误信息:

10530
来自专栏码匠的流水账

聊聊sentinel的SimpleHttpCommandCenter

sentinel-transport-simple-http-0.1.1-sources.jar!/com/alibaba/csp/sentinel/trans...

9510
来自专栏Spark学习技巧

textFile构建RDD的分区及compute计算策略

1,textFile A),第一点,就是输入格式,key,value类型及并行度的意义。 def textFile( path: String, mi...

25970
来自专栏LhWorld哥陪你聊算法

【Storm篇】--Storm分组策略

Storm由数源泉spout到bolt时,可以选择分组策略,实现对spout发出的数据的分发。对多个并行度的时候有用。

20120
来自专栏Spark学习技巧

重要 : 优化flink的四种方式

flink这个框架在逐步变为流处理的主流。本文,我们将针对flink性能调优讲四种不同的方法。

45620

扫码关注云+社区

领取腾讯云代金券