HBase - Coprocessor - 协处理器之观察者Observer（触发器）的介绍以及使用 | 那伊抹微笑

时间：2022-02-10 08:26:43
博文作者： 那伊抹微笑
csdn 博客地址： http://blog.csdn.net/u012185296
itdog8 地址链接 : http://www.itdog8.com/thread-216-1-1.html
 博文标题：HBase - Coprocessor - 协处理器之观察者Observer（触发器）的介绍以及使用 | 那伊抹微笑
个性签名： 世界上最遥远的距离不是天涯，也不是海角，而是我站在妳的面前，妳却感觉不到我的存在
技术方向： Flume+Kafka+Storm+Redis/Hbase+Hadoop+Hive+Mahout+Spark ... 云计算技术
转载声明： 可以转载, 但必须以超链接形式标明文章原始出处和作者信息及版权声明，谢谢合作！
qq交流群：214293307  HBase - Coprocessor - 协处理器之观察者Observer（触发器）的介绍以及使用 | 那伊抹微笑（期待与你一起学习，共同进步）



1 协处理器
协处理器分为  观察者 Observer 和 终端 Endpoint

1.1 观察者 Observer（类似传统数据库中的触发器 Trigger）

1.1.1 Coprocessor 下的接口

详细信息直接看接口上的注释吧！！！

1.1.2 Java API 的使用
继承对应的抽象类就行了，每个抽象类有不同的功能，见名知意，不解释 、、、

public class TestAddColumnBaseRegionObserver extends BaseRegionObserver{
 
 @Override
 public void prePut(ObserverContext<RegionCoprocessorEnvironment> e, Put put, WALEdit edit, Durability durability) throws IOException {
  putUUIDColumnIfMissing(e, put, edit, durability);
 }
 
 private void putUUIDColumnIfMissing(ObserverContext<RegionCoprocessorEnvironment> e, Put put, WALEdit edit, Durability durability) {
  try {
   if(!put.has(Bytes.toBytes("cf1"), Bytes.toBytes("uuid"))) {
    String uuid = MD5Util.encrypt(put.toString());
    put.add(Bytes.toBytes("cf1"), Bytes.toBytes("uuid"), Bytes.toBytes(uuid));
   }
  } catch (Exception e1) {
   e1.printStackTrace();
  }
 }
}

1.1.3 打成 itdog8-yting-hbase-coprocessor-observer-1.0.0.jar 并上传到 hdfs（hbase shell 方式加载 coprocessor 要用到）
bash-4.1$ hadoop fs -put /usr/yting/hbase/coprocessor/test/itdog8-yting-hbase-coprocessor-observer-1.0.0.jar /usr/itdog8/yting/hbase/coprocessor/test/

1.1.4 hbase shell 方式加载 Coprocessor
hbase(main):017:0> alter 'itdog8:hbase_coprocessor_test_1', 'coprocessor'=>'hdfs:///usr/yting/hbase/coprocessor/test/itdog8-yting-hbase-coprocessor-observer-1.0.0.jar|com.itdog8.study.cloud.hbase.coprocessor.observer.TestAddColumnBaseRegionObserver|1001|arg1=1,arg2=2'
Updating all regions with the new schema...
0/1 regions updated.
1/1 regions updated.
Done.
0 row(s) in 2.1490 seconds

1.1.5 测试
hbase(main):025:0> scan 'itdog8:hbase_coprocessor_test_1'
ROW                                                 COLUMN+CELL                                                                                                                                            
0 row(s) in 0.0130 seconds

hbase(main):026:0> put 'itdog8:hbase_coprocessor_test_1', 'row-zhagnsan', 'cf1:name', 'zhangsan'
0 row(s) in 0.0120 seconds

hbase(main):027:0> scan 'itdog8:hbase_coprocessor_test_1'
ROW                                                 COLUMN+CELL                                                                                                                                            
 row-zhagnsan                                       column=cf1:name, timestamp=1438919899641, value=zhangsan                                                                                              
 row-zhagnsan                                       column=cf1:uuid, timestamp=1438919899641, value=2a66e9ed97e9ded4c21d1ef555cfa69e                                                                      
1 row(s) in 0.0110 seconds

hbase(main):028:0> 

可以发现 HBase-Coprocessor-Observer（触发器）成功触发并执行了（还是叫触发器习惯点，也更容易理解）
我们put数据的时候，没有uuid的时候他put了uuid进去了
OK

1.1.6 hbase shell 方式卸载 Coprocessor
alter 'itdog8:hbase_coprocessor_test_1', METHOD => 'table_att_unset', NAME => 'coprocessor$1'

1.2 终端 Endpoint（类似传统数据库中的 存储过程）


标签：

相关文章