1. 程式人生 > >hbase(十)-hbase查詢,scan filter的使用

hbase(十)-hbase查詢,scan filter的使用

1.Scan

HBase常用的檢視資料方式有scan和get,get是一種特殊的scan,get是scan的startrow和endrow等於同一個值的特殊情況。

hbase的rowkey是按照B+樹的形式存放的,所以查詢一個具體的rowkey速度是非常快的,所以查詢資料的時候一般都會設定scan的startrow和endrow,這樣可以縮小查詢的範圍,所以rowkey的設計在hbase裡面是極為重要的。

可以這樣講,hbase裡面的查詢資料只有scan一種形式,就是在B+樹裡面查詢rowkey,而scan就是對rowkey的一種順序”掃”。

檢視一下scan裡面對rowkey的條件篩選,只有startrow和endrow這一組,所以可以理解為sql條件裡面的”>”和”<”。

hbase的rowkey是按照順序排列的,所以在設計rowkey的時候儘量將業務查詢需要的欄位設計到rowkey裡面,這樣在查詢的時候對rowkey加上一定範圍的限制。

Scan scan = new Scan();
scan.setStartRow("001".getBytes());
scan.setStopRow("1000".getBytes());
scan.setCaching(10000);//hbase掃描時的快取
scan.setBatch(100);//一次掃描資料

2.Filter

除了對rowkey的scan外,HBase為篩選資料提供了一組過濾器,通過這個過濾器可以在HBase中的資料的多個維度(行,列,資料版本)上進行對資料的篩選操作,也就是說過濾器最終能夠篩選的資料能夠細化到具體的一個儲存單元格上(由行鍵,列明,時間戳定位)。

filter並不能做到像rowkey那樣快速定位到資料,他的作用僅僅是過濾,在scan的過程中對列族的某個欄位進行一定條件的判斷。

通常來講,scan來定位查詢的大概範圍,fitler來過濾找到具體的值。

下面看看hbase裡面都提供了哪些filter

2.1. RowFilter

篩選出匹配的所有的行,對於這個過濾器的應用場景,是非常直觀的:使用BinaryComparator可以篩選出具有某個行鍵的行,或者通過改變比較運算子(下面的例子中是CompareFilter.CompareOp.EQUAL)來篩選出符合某一條件的多條資料,以下就是篩選出行鍵為row1的一行資料:

Filter rf = new
RowFilter(CompareFilter.CompareOp.EQUAL, new BinaryComparator(Bytes.toBytes("row1"))); // OK 篩選出匹配的所有的行

2.2. PrefixFilter

篩選出具有特定字首的行鍵的資料。這個過濾器所實現的功能其實也可以由RowFilter結合RegexComparator來實現,不過這裡提供了一種簡便的使用方法,以下過濾器就是篩選出行鍵以row為字首的所有的行:

Filter pf = new PrefixFilter(Bytes.toBytes("row")); // OK  篩選匹配行鍵的字首成功的行  

2.3. KeyOnlyFilter

這個過濾器唯一的功能就是隻返回每行的行鍵,值全部為空,這對於只關注於行鍵的應用場景來說非常合適,這樣忽略掉其值就可以減少傳遞到客戶端的資料量,能起到一定的優化作用:

Filter kof = new KeyOnlyFilter(); // OK 返回所有的行,但值全是空  

2.4. RandomRowFilter

從名字上就可以看出其大概的用法,本過濾器的作用就是按照一定的機率(<=0會過濾掉所有的行,>=1會包含所有的行)來返回隨機的結果集,對於同樣的資料集,多次使用同一個RandomRowFilter會返回不通的結果集,對於需要隨機抽取一部分資料的應用場景,可以使用此過濾器:

Filter rrf = new RandomRowFilter((float) 0.8); // OK 隨機選出一部分的行  

2.5. InclusiveStopFilter

掃描的時候,我們可以設定一個開始行鍵和一個終止行鍵,預設情況下,這個行鍵的返回是前閉後開區間,即包含起始行,但不包含終止行,如果我們想要同時包含起始行和終止行,那麼我們可以使用此過濾器:

Filter isf = new InclusiveStopFilter(Bytes.toBytes("row1")); // OK 包含了掃描的上限在結果之內  

2.6. FirstKeyOnlyFilter

如果你只想返回的結果集中只包含第一列的資料,那麼這個過濾器能夠滿足你的要求。它在找到每行的第一列之後會停止掃描,從而使掃描的效能也得到了一定的提升:

Filter fkof = new FirstKeyOnlyFilter(); // OK 篩選出第一個每個第一個單元格  

2.7. ColumnPrefixFilter

顧名思義,它是按照列名的字首來篩選單元格的,如果我們想要對返回的列的字首加以限制的話,可以使用這個過濾器:

Filter cpf = new ColumnPrefixFilter(Bytes.toBytes("qual1")); // OK 篩選出字首匹配的列  

2.8. ValueFilter

按照具體的值來篩選單元格的過濾器,這會把一行中值不能滿足的單元格過濾掉,如下面的構造器,對於每一行的一個列,如果其對應的值不包含ROW2_QUAL1,那麼這個列就不會返回給客戶端:

Filter vf = new ValueFilter(CompareFilter.CompareOp.EQUAL, new SubstringComparator("ROW2_QUAL1")); // OK 篩選某個(值的條件滿足的)特定的單元格  

2.9. ColumnCountGetFilter

這個過濾器來返回每行最多返回多少列,並在遇到一行的列數超過我們所設定的限制值的時候,結束掃描操作:

Filter ccf = new ColumnCountGetFilter(2); // OK 如果突然發現一行中的列數超過設定的最大值時,整個掃描操作會停止  

2.10. SingleColumnValueFilter

用一列的值決定這一行的資料是否被過濾。在它的具體物件上,可以呼叫setFilterIfMissing(true)或者setFilterIfMissing(false),預設的值是false,其作用是,對於咱們要使用作為條件的列,如果這一列本身就不存在,那麼如果為true,這樣的行將會被過濾掉,如果為false,這樣的行會包含在結果集中。

SingleColumnValueFilter scvf = new SingleColumnValueFilter(  
        Bytes.toBytes("colfam1"),   
        Bytes.toBytes("qual2"),   
        CompareFilter.CompareOp.NOT_EQUAL,   
        new SubstringComparator("BOGUS"));  
scvf.setFilterIfMissing(false);  
scvf.setLatestVersionOnly(true); // OK  

2.11. SingleColumnValueExcludeFilter

這個與10種的過濾器唯一的區別就是,作為篩選條件的列的不會包含在返回的結果中。

2.12. SkipFilter

這是一種附加過濾器,其與ValueFilter結合使用,如果發現一行中的某一列不符合條件,那麼整行就會被過濾掉:

Filter skf = new SkipFilter(vf); // OK 發現某一行中的一列需要過濾時,整個行就會被過濾掉  

2.13. WhileMatchFilter

這個過濾器的應用場景也很簡單,如果你想要在遇到某種條件資料之前的資料時,就可以使用這個過濾器;當遇到不符合設定條件的資料的時候,整個掃描也就結束了:

Filter wmf = new WhileMatchFilter(rf); // OK 類似於Python itertools中的takewhile  

2.14. FilterList

用於綜合使用多個過濾器。其有兩種關係:FilterList.Operator.MUST_PASS_ONE和FilterList.Operator.MUST_PASS_ALL,預設的是FilterList.Operator.MUST_PASS_ALL,顧名思義,它們分別是AND和OR的關係,並且FilterList可以巢狀使用FilterList,使我們能夠表達更多的需求:

List<Filter> filters = new ArrayList<Filter>();  
filters.add(rf);  
filters.add(vf);  
FilterList fl = new FilterList(FilterList.Operator.MUST_PASS_ALL, filters); // OK 綜合使用多個過濾器, AND 和 OR 兩種關係