hbase reginobserver，

hbase reginobserver，

协处理器

RegionObserver
---------------
触发器。
面向列族数据库。
多版本化。
put //insert
get //查询
scan//扫描
delete //删除(key-value).

key(rowkey/f:col/timestamp = xxxx)

启动hbase集群,进入hbase shell下，查看数据。

Get g = new Get("rowkey");
g.set

get(Get g);


思考题
----------
calllogs数据插入时，rowkey的计算法则是固定切叫复杂。
通过协处理器的prePut()方法实现统一的计算和处理。
hashcode:()...,,,,


put(Put(rowkey))


编写区域观察者,对客户端透明的。
-----------------------------------------------------------
导出项目成jar文件，并放置到hbase的/lib下,进行分发,重启集群。
postPut(){...}


透明处理查询通话指定rowkey的记录问题,对客户端透明的。
------------------------------------------------------------------------
查询通话记录的数据，不论主叫还是被叫，都能查询出全部的通话信息。
postGetOp(){...}


按照时间段进行数据的查询,对客户端透明的。
------------------------------------------------
postScannerNext(){...}
...



部署协处理器(Regionobserver)
-----------------------------
1.编写程序导出jar，放置到hbase/lib下，并进行分发。

2.配置hbase的配置文件。
[hbase/conf/hbase-site.xml]
...
        <property>
                <name>hbase.coprocessor.region.classes</name>
                <value>com.it18zhang.calllog.coprossor.CallLogRegionObserver</value>
        </property>

3.重启hbase集群

start-hbase.sh

源码：

https://download.csdn.net/download/jiangdaquan/10534806