根据限定符只返回一行数据,不存在:
public static void addQualifierFilter(FilterList list, byte[] family, byte[] qualifier) { byte[] fakeValue = Bytes.toBytes("DOESNOTEXIST"); SingleColumnValueFilter filter = new SingleColumnValueFilter(family, qualifier, CompareOp.NOT_EQUAL, fakeValue); filter.setFilterIfMissing(true); list.addFilter(filter); }
根据限定符选出不包含没有数据的:
public static void addQualifierExcludeFilter(FilterList list, byte[] family, byte[] qualifier) { SkipFilter filter = new SkipFilter(new QualifierFilter(CompareOp.NOT_EQUAL, new BinaryComparator(qualifier))); list.addFilter(filter); }
根据时间来过滤:
public static void addTimeStampFilter(FilterList list, byte[] family, byte[] qualifier, byte[] timestamp) { SingleColumnValueFilter filter = new SingleColumnValueFilter(family, qualifier, CompareOp.GREATER_OR_EQUAL, timestamp); list.addFilter(filter); }
根据时间来过滤(不包含指定的时间):
public static void addTimeStampExcludeFilter(FilterList list, byte[] family, byte[] qualifier, byte[] timestamp) { SingleColumnValueExcludeFilter filter = new SingleColumnValueExcludeFilter(family, qualifier, CompareOp.GREATER_OR_EQUAL, timestamp); list.addFilter(filter); }
使用方法:
FilterList list = new FilterList(); HBaseManager.addQualifierFilter(list, HTableConstant.USER_HOBBY_HOBBY_COLUMN_FAMILY, HTableConstant.USER_HOBBY_USER_ID_QUALIFIER); HBaseManager.addTimeStampFilter(list, HTableConstant.USER_HOBBY_HOBBY_COLUMN_FAMILY, HTableConstant.USER_HOBBY_DATE_QUALIFIER, Bytes.toBytes(date)); scan.setFilter(list);
相关推荐
Hbase过滤器详解,基础篇
过滤器可以根据列族、列、版本等更多的条件来对数据进行过滤,基于 HBase 本身提供的三维有序(行键,列,版本有序),这些过滤器可以高效地完成查询过滤的任务,带有过滤器条件的 RPC 查询请求会把过滤器分发到各个...
NULL 博文链接:https://zy19982004.iteye.com/blog/2088173
java操作Hbase之Hbase专用过滤器PageFilter的使用源代码,附带全部所需源代码,欢迎下载学习。
java操作Hbase之比较过滤器RowFilter的使用源码,附带所需全部jar包,欢迎下载学习。
介绍布隆过滤器的原理,实现,结构,优缺点,以及误判率估计和最优哈希个数,其中还有含有公式的详细推到过程。
博主自己整理的一些HBASE的注意事项,可能比较LOW,大家凑活看看。
课时8:过滤器实战之专用过滤器与FilterList 课时9:过滤器实战之自定义过滤器 课时10:Observer协处理器实战之Master级别原理剖析 课时11:Observer协处理器实战之Region级别原理剖析 课时12:Observer协处理器...
可以通过GUI管理Hbase数据库,支持多种过滤器查询。
1 HBase分享六、Thrift接口查询、Scan过滤器 1.1 依据行键和列族过滤 1.2 据行键开始、行键结束和列族过滤 1.3 通过行键前缀进行查询 1.4 查找在当前指定时间之前且大于等于startRowKey行键记录; 1.5 查找在当前...
3-1 HBase写流程 3-2 HBase读流程 3-3 HBase模块协作 3-4 HBase实战:Shell命令实战 3-5 HBase实 战:Java Api实现HBase连接类 3-6 HBase实战:Java Api实现HBase操作类 3-7 HBase实战:用过滤器筛选数据 3-8 HBase...
Apache Phoenix是构建在HBase之上的关系型数据库层,作为内嵌的客户端JDBC驱动用以对...直接使用HBase的API,结合协处理器(coprocessor)和自定义的过滤器的话,小范围的查询在毫秒级响应,千万数据的话响应速度为秒级
本文接着上期介绍的”简单了解Hbase及快速入手之入门教程_01“,着重介绍了hbase的伪分布式部署以及hbase的过滤器。适合刚入门或者刚接触的小伙伴参考。
14.hbase中判断数据是否在一个持久化文件中的机制--布隆过滤器.mp4
对于使用了HBase API、协同处理器及自定义过滤器的Impala与OpenTSDB来说,进行相似的查询Phoenix的速度也会更快一些。 Phoenix查询引擎会将SQL查询转换为一个或多个HBase scan,并编排执行以生成标准的JDBC结果集...
性能比较环境细节资料大小事件表包含500万条记录和90个字段工人3 硬件16个逻辑核心64GB内存(分别为Presto和HBase 16GB内存)4T * 2硬盘 详细信息: : 功能点比较功能性易观其他盐渍表支持的不支持按开始键和结束键...
HBase初学者
HBase分布式NoSQL数据库实验 1.HBase基础 HBase伪分布式部署 HBase Shell接口操作 HBase Web UI管理 2.HBase数据管理 HBase DDL操作 HBase DML操作 练习1:HBase Shell操作 练习2:HBase Shell数据...编程应用过滤器
所以大家如果看本文的话,就全当是加深对hbase过滤器的理解吧,内容概括起来就是实现一个使用位运算的比较器。本文主要内容是通过合理hbase行键(rowkey)设计实现快速的多条件查询,所采用的方法将所有要用于查询中...