Hbase高級(jí)功能過濾怎么使用

本篇內(nèi)容主要講解“Hbase高級(jí)功能過濾怎么使用”，感興趣的朋友不妨來看看。本文介紹的方法操作簡單快捷，實(shí)用性強(qiáng)。下面就讓小編來帶大家學(xué)習(xí)“Hbase高級(jí)功能過濾怎么使用”吧!

1.創(chuàng)建一個(gè)Rumenz表

// 創(chuàng)建了兩個(gè)列族user和depart
> ./bin/hbase shell
> create 'Rumenz','user','depart'

2.插入數(shù)據(jù)

> put 'Rumenz','user|id1','user:name','張三'
> put 'Rumenz','user|id1','depart:name','開發(fā)部'
> 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.一個(gè)rowkey可能有會(huì)多個(gè)版本,通過FirstKeyOnlyFilter可以獲取最新版本的數(shù)據(jù).獲取最新數(shù)據(jù)中值中包含部的數(shù)據(jù)

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

9.一個(gè)rowkey可能有會(huì)多個(gè)版本,通過FirstKeyOnlyFilter可以獲取最新版本的數(shù)據(jù).獲取最新數(shù)據(jù)中值中包含部的數(shù)據(jù)并且只返回key不需要value

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

10.從user|id2行開始,查詢r(jià)owkey以user開頭的數(shù)據(jù)

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

11.查找rowkey中包含id的數(shù)據(jù)

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

12.查找user:name列值為王五的數(shù)據(jù)并只顯示user:name列

//顯示多個(gè)列使用COLUMNS => ['user:name','xxxx']
>scan 'Rumenz', {COLUMNS => 'user:name', FILTER => SingleColumnValueFilter.new(Bytes.toBytes('user'), Bytes.toBytes('name'), CompareFilter::CompareOp.valueOf('EQUAL'), Bytes.toBytes('王五'))}到此，相信大家對(duì)“Hbase高級(jí)功能過濾怎么使用”有了更深的了解，不妨來實(shí)際操作一番吧！這里是億速云網(wǎng)站，更多相關(guān)內(nèi)容可以進(jìn)入相關(guān)頻道進(jìn)行查詢，關(guān)注我們，繼續(xù)學(xué)習(xí)！