Hbase高级功能过滤怎么使用
本篇内容主要讲解“Hbase高级功能过滤怎么使用”,感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷,实用性强。下面就让小编来带大家学习“Hbase高级功能过滤怎么使用”吧!
创新互联公司是一家专注于成都网站建设、做网站与策划设计,梅列网站建设哪家好?创新互联公司做网站,专注于网站建设10余年,网设计领域的专业建站公司;建站业务涵盖:梅列等地区。梅列做网站价格咨询:13518219792
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('user'), Bytes.toBytes('name'), CompareFilter::CompareOp.valueOf('EQUAL'), Bytes.toBytes('王五'))}到此,相信大家对“Hbase高级功能过滤怎么使用”有了更深的了解,不妨来实际操作一番吧!这里是创新互联网站,更多相关内容可以进入相关频道进行查询,关注我们,继续学习!
网站名称:Hbase高级功能过滤怎么使用
分享网址:http://azwzsj.com/article/iepphg.html