Hbase协处理器coprocessor
对每个region进行处理,弥补了scan的时候有限的几个过滤器的不足
成都创新互联公司专注为客户提供全方位的互联网综合服务,包含不限于成都做网站、成都网站设计、铜鼓网络推广、重庆小程序开发、铜鼓网络营销、铜鼓企业策划、铜鼓品牌公关、搜索引擎seo、人物专访、企业宣传片、企业代运营等,从售前售中售后,我们都将竭诚为您服务,您的肯定,是我们最大的嘉奖;成都创新互联公司为所有大学生创业者提供铜鼓建站搭建服务,24小时服务热线:18982081108,官方网址:www.cdcxhl.com
分为两种类型
observer 观察者相当于触发器
Endpoint终端相当于存储过程
下面的观察者实现查询之前替换掉行键为Jack的KeyValue
import java.io.IOException; import java.util.List; import org.apache.hadoop.hbase.KeyValue; import org.apache.hadoop.hbase.client.Get; import org.apache.hadoop.hbase.coprocessor.BaseRegionObserver; import org.apache.hadoop.hbase.coprocessor.ObserverContext; import org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment; import org.apache.hadoop.hbase.util.Bytes; public class RegionObserverTest extends BaseRegionObserver { private static byte[] fixed_rowkey = "Jack".getBytes(); @Override public void postGet(ObserverContextc, Get get, List result) throws IOException { if (Bytes.equals(get.getRow(), fixed_rowkey)) { KeyValue kv = new KeyValue(get.getRow(), Bytes.toBytes("time"), Bytes.toBytes("time"), Bytes.toBytes(System .currentTimeMillis())); result.add(kv); } } }
加载协处理器命令
disable 'students' alter 'students' ,'coprocessor'=>'hdfs://ns1/coprocessor.jar|com.hbase.RegionObserverTest||' enable 'students'
alter 'table_name' ,METHOD=>'table_att', 'coprocessor'=>'path|class|number|args'
number表示第几个协处理器
删除第一个协处理器
alter 'table_name' ,METHOD=>'table_att_unset',NAME=>'coprocessor$1'
名称栏目:Hbase协处理器coprocessor
本文来源:http://scyanting.com/article/gdggpj.html