对每个region进行处理，弥补了scan的时候有限的几个过滤器的不足
分为两种类型
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(ObserverContext<RegionCoprocessorEnvironment> c,
Get get, List<KeyValue> 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'
亿速云「云服务器」，即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘，价格低至29元/月。点击查看>>
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
