hbase的所有過濾器

2021-09-05 12:10:14 字數 2862 閱讀 4348

一：hbase的所有過濾器用法：

１．keyonlyfilter

filter_str = "keyonlyfilter()" 


table = connection.table(table_name)


table.scan(filter=filter_str)
返回所有行和列簇資料，值為空。

２．firstkeyonlyfilter

filter_str = "firstkeyonlyfilter()" 


table = connection.table(table_name)


table.scan(filter=filter_str)
返回所有行和列的資料。

３．prefixfilter

filter_str = "prefixfilter('row_key')" 


table = connection.table(table_name)


table.scan(filter=filter_str)
篩選出具有特定字首的行鍵的資料，即通過row_key的字首查詢並返回特定行的資料。

４．columnprefixfilter

filter_str = "columnprefixfilter('column')" 


table = connection.table(table_name)


table.scan(filter=filter_str)
篩選出具有特定字首的列簇的資料，即通過列簇的字首查詢並返回特定行的資料。

５．multiplecolumnprefixfilter

filter_str = "multiplecolumnprefixfilter('column1','column2')" 


table = connection.table(table_name)


table.scan(filter=filter_str)
篩選出具有特定字首的列簇的資料，字首可以是乙個列表，即通過列簇的字首查詢並返回特定行的資料。

６．columncountgetfilter

filter_str = "columncountgetfilter(a)" 


table = connection.table(table_name)


table.scan(filter=filter_str)
從第一行開始讀取資料，一直讀取到某一行的列數大於設定的閾值a時停止，並返回當前讀取到的資料。

７．pagefilter

filter_str = "pagefilter(10)" 


table = connection.table(table_name)


table.scan(filter=filter_str)
返回特定行數的資料。

８．columnpaginationfilter

filter_str = "columnpaginationfilter(a,b)" 


table = connection.table(table_name)


table.scan(filter=filter_str)
對於所有的行，從第b列開始，讀取a列，並返回。

９．inclusivestopfilter

filter_str = "inclusivestopfilter('row_key')" 


table = connection.table(table_name)


table.scan(filter=filter_str)
從頭開始讀取資料，一直讀取到設定的row_key這一行，然後返回讀取到的所有資料。

１０．timestampsfilter

１１．rowfilter

filter_str = "rowfilter(=,'regexstring:aa*bb')" 


table = connection.table(table_name)


table.scan(filter=filter_str)
按照行的條件查詢資料，引數包含比較運算子（等於=，不等於!=，大於》，小於

１２．family filter

１３．qualifierfilter

１４．valuefilter

１５．dependentcolumnfilter

１６．singlecolumnvaluefilter

１７．singlecolumnvalueexcludefilter

１８．columnrangefilter

二：參考位址部分截圖

香菸過後，手留余香，而你呢...

Hbase 過濾器（所有過濾）

filter介面中定義了過濾器的基本方法，filterbase抽象類實現了filter介面。所有內建的過濾器則直接或者間接繼承自filterbase抽象類。使用者只需要將定義好的過濾器通過setfilter方法傳遞給scan或put的例項即可。scan 中定義的setfilter override ...

hbase 過濾器 scala 過濾器系列

過濾器系列710 c30810 賓士 c64 1500 004 09411 04 004094 3504 h12 110 2 w11102 2 wdk724 wdk725 沃爾沃 3825778 8149064 3825133 3825215 466634 11110668 11711074 477...

HBase（七）Hbase過濾器

基礎api中的查詢操作在面對大量資料的時候是非常蒼白的，這裡hbase提供了高階的查詢方法 filter。filter可以根據簇 列 版本等更多的條件來對資料進行過濾，基於hbase本身提供的三維有序 主鍵有序 列有序 版本有序 這些filter可以高效的完成查詢過濾的任務。帶有filter條件的r...