Hbase Filter運算元大全

2021-08-21 03:06:53 字數 1485 閱讀 6415

public

static

void

valuefilterexam

()throws exception}}

//執行了三個過濾器,速度比較慢

public

static

void

filterlistexam

()throws exception}}

//分頁過濾器

public

static

void

pagefilterexam

()throws exception}}

//行過濾器

public

static

void

rowfilterexam

()throws exception

)));

table table = connection.gettable(tablename.valueof("test"));

//構建從rok-001 到rk-003的range

multirowrangefilter.rowrange rowrange1 = new multirowrangefilter.rowrange("rk-001", true, "rk-003", true);

//構建從rok-005 到rk-007的range

multirowrangefilter.rowrange rowrange2 = new multirowrangefilter.rowrange("rk-005", true, "rk-007", true);

rowlist.add(rowrange1);

multirowrangefilter multirowrangefilter = new multirowrangefilter(rowlist);

scan scan =new scan();

//行過濾器

過濾出rowkey > rk-001的

//filter rowfilter = new rowfilter(comparefilter.compareop.greater,new binarycomparator(bytes.tobytes("rk-001")));

scan.setfilter(multirowrangefilter);

resultscanner scannerresult = table.getscanner(scan);

for (result rs:scannerresult) }}

//列過濾器

public

static

void

qualifilterexam

()throws exception}}

//單元格和裝飾過濾器

public

static

void

cellfilterexam

()throws exception

}}

hbase filter作用列表

網上以及hbase相關書籍中有許多關於hbase的過濾器的使用介紹,這邊簡單羅列一下hbase自帶的各個過濾器並簡述一下功能,方便以後一目了然地查詢使用。1.rowfilter 基於行鍵來過濾資料 2.familyfilter 基於列族 名 來過濾資料 3.qualifierfilter 基於列名來...

HBase Filter 過濾器概述

abc hbase過濾器是一套為完成一些較高階的需求所提供的api介面。過濾器也被稱為下推判斷器 push down predicates 支援把資料過濾標準從客戶端下推到伺服器,帶有 filter 條件的 rpc 查詢請求會把 filter 分發到各個 regionserver,所有的過濾器都在服...

大資料教程HBase Filter過濾器概述

好程式設計師大資料培訓分享hbase filter過濾器概述,過濾器介紹 hbase過濾器是一套為完成一些較高階的需求所提供的api介面。過濾器也被稱為下推判斷器 push down predicates 支援把資料過濾標準從客戶端下推到伺服器,帶有 filter 條件的 rpc 查詢請求會把 fi...