Hbase高级功能过滤(Filter)

男娘i 2022-09-12 01:53 207阅读 0赞

1.创建一个`Rumenz`表

// 创建了两个列族user和depart
    > ./bin/hbase shell
    > create 'Rumenz','user','depart'

2.插入数据

> put 'Rumenz','user|id1','user:name','张三'
    > put 'Rumenz','user|id1','depart:name','开发部'
    > put 'Rumenz','user|id2','user:name','王五'
    > put 'Rumenz','user|id2','depart:name','市场部'
    > put 'Rumenz','user|tsc','user:name','入门'
    > put 'Rumenz','user1|id1','user:name','小站'

3.找出值为`张三`的记录

> scan 'Rumenz',FILTER=>"ValueFilter(=,'binary:张三')"

4.找出值中包含`部`字的记录

> scan 'Rumenz',FILTER=>"ValueFilter(=,'substring:部')"

5.找出列名以`dep`开头的记录

> scan 'Rumenz',FILTER=>"ColumnPrefixFilter('dep')"

6.找出列名以`ts`开头并且值为`入门`的值

> scan 'Rumenz',FILTER=>"ColumnPrefixFilter('ts') AND ValueFilter(=,'binary:入门')"

7.找出rowkey以`user1`开头

> scan 'Rumenz',FILTER=>"PrefixFilter('user1')"

8.一个rowkey可能有会多个版本,通过FirstKeyOnlyFilter可以获取最新版本的数据.获取最新数据中值中包含`部`的数据

> scan 'Rumenz',FILTER=>"FirstKeyOnlyFilter() and ValueFilter(=,'substring:部')"

9.一个rowkey可能有会多个版本,通过FirstKeyOnlyFilter可以获取最新版本的数据.获取最新数据中值中包含`部`的数据并且只返回key不需要value

> scan 'Rumenz',FILTER=>"FirstKeyOnlyFilter() and ValueFilter(=,'substring:部') AND KeyOnlyFilter()"

10.从`user|id2`行开始,查询rowkey以`user`开头的数据

> sacn 'Rumenz',{STARTROW=>'user|id2',FILTER=>"PrefixFilter('user')"}

11.查找rowkey中包含`id`的数据

> scan 'Rumenz', {FILTER => RowFilter.new(CompareFilter::CompareOp.valueOf('EQUAL'), SubstringComparator.new('id'))}

12.查找`user:name`列值为`王五`的数据并只显示`user:name`列

//显示多个列使用COLUMNS => ['user:name','xxxx']
    >scan 'Rumenz', {COLUMNS => 'user:name', FILTER => SingleColumnValueFilter.new(Bytes.toBytes('u

发表评论取消回复

表情：

评论列表（有 0 条评论，207人围观）

还没有评论，来说两句吧...

相关阅读

相关 Elasticsearch filter过滤查询

注：本实例代码是在ES marvel插件中执行 \ --------------------------------------- \ filter 查询

淡淡的烟草味﹌/ 2023年01月14日 01:50/ 0 赞/ 215 阅读

相关 SpringBoot Filter 过滤

1.通过扫描注解完成Filter组件注册 1. 创建一个类，实现Filter接口,实现doFilter()方法 2. 在该类使用注解@WebFilter，设置filter

我会带着你远行/ 2022年12月17日 03:29/ 0 赞/ 213 阅读

相关 Hbase高级

目录 RegionServer 架构总结写流程总结读流程

谁借莪１个温暖的怀抱￠/ 2022年11月26日 07:38/ 0 赞/ 152 阅读

相关 Stream filter过滤案例

package com.gblfy.gxts; import com.google.common.collect.Lists; import

左手的ㄟ右手/ 2022年10月16日 07:51/ 0 赞/ 214 阅读

相关 Hbase高级功能过滤(Filter)

1.创建一个`Rumenz`表 // 创建了两个列族user和depart > ./bin/hbase shell > create 'Rumenz'

男娘i/ 2022年09月12日 01:53/ 0 赞/ 208 阅读

相关 Filtering 过滤操作

[`filter( )`][filter] — 过滤数据 [`takeLast( )`][takeLast] — 只发射最后的N项数据 [`last( )`]

冷不防/ 2022年07月29日 10:35/ 0 赞/ 220 阅读

相关 hbase shell Filter

数据： hbase(main):046:0> scan 'hbaseFilter' ROW

待我称王封你为后i/ 2022年06月13日 09:55/ 0 赞/ 219 阅读

相关 hbase Filter

get和sacn可以用过滤器。 1.FilterList 这是一个过滤器列表，可以指定FilterList.Operator.MUST\_PASS\_A

痛定思痛。/ 2022年06月13日 09:30/ 0 赞/ 174 阅读

相关过滤查询filter angularjs

find.html [?][Link 1] <table style="border-collapse:collapse; border-spacing:0px; bord

小灰灰/ 2022年06月05日 00:39/ 0 赞/ 288 阅读

相关使用filter过滤数据

如何筛选掉无效数据？今天在做遍历20个数据时，需要判断后台返回的数据是否含user字段，有则遍历，无则跳过，如何实现呢？刚开始想复杂了，我的做法是，用数组arr1,

客官°小女子只卖身不卖艺/ 2021年07月25日 21:42/ 0 赞/ 458 阅读