设为首页 加入收藏

TOP

hbase 过滤器 rowfilter(二)
2019-09-17 18:54:00 】 浏览:62
Tags:hbase 过滤器 rowfilter
2,h203"); try{ HTable table = new HTable(config, Bytes.toBytes("student1")); Scan scan = new Scan(); Filter filter1 = new RowFilter(CompareFilter.CompareOp.EQUAL,new BinaryComparator("a101".getBytes())); scan.setFilter(filter1); ResultScanner rst = table.getScanner(scan); for (Result r:rst){ for (KeyValue kv : r.raw()) { StringBuffer s1 = new StringBuffer() .append(Bytes.toString(kv.getRow())).append(":") .append(Bytes.toString(kv.getFamily())).append(",") .append(Bytes.toString(kv.getQualifier())).append(",") .append(Bytes.toString(kv.getValue())); System.out.println(s1.toString()); } } rst.close(); table.close(); } catch(IOException e) { e.printStackTrace(); } } }

1.2
PrefixFilter:筛选出具有特定前缀的行键的数据。这个过滤器所实现的功能其实也可以由RowFilter结合RegexStringComparator来实现,不过这里提供了一种简便的使用方法

import org.apache.hadoop.hbase.filter.PrefixFilter;
Filter filter2 = new PrefixFilter(Bytes.toBytes("a"));
scan.setFilter(filter2);

1.3
RegexComparator 正则过滤
import org.apache.hadoop.hbase.filter.RegexStringComparator;
Filter filter3 = new RowFilter(CompareFilter.CompareOp.EQUAL,new RegexStringComparator("^a.*"));
 scan.setFilter(filter3);

 

首页 上一页 1 2 下一页 尾页 2/2/2
】【打印繁体】【投稿】【收藏】 【推荐】【举报】【评论】 【关闭】 【返回顶部
上一篇Mysql5.7登录错误1045和1130的解.. 下一篇记一次异机rman还原后的操作

最新文章

热门文章

Hot 文章

Python

C 语言

C++基础

大数据基础

linux编程基础

C/C++面试题目