HBase协处理器知识点

时间:2021-08-28 08:27:23

                                                                                                   HBase协处理器知识点

1、为什么引入协处理器?

     在旧版(0.92HBase版本之前)的HBase中是没有引入协处理器的概念的。这样存在的问题是:创建二级索引较难,很难进行简单的排序、求和、计数等操作。这里是指在该版本限制下难以进行上述操作,不是不行。为了降低难度,提出了协处理器的概念。

 这里补充索引相关的知识点:

索引的概念:

i)明确是针对数据库而言的,体现是一张表或者一种数据结构,一列或者多列,目的是用来快速访问数据库中的信息。包含的内容是:键的属性值和存储文件位置信息的指针。

ii)主索引:

主索引是包含两个定长字段的有序文件。字段1:主键;字段2:磁盘块的指针。 这两个字段的值是索引项的值。

ii)二级索引

二级索引的概念:
“二级索引也是有两个字段的有序文件:
第一个字段是索引字段,有相同的数据类型,并且是数据文件中的非排序字段,

第二个字段可以是一个块指针也可以是记录指针。二级索引(也称为非聚簇索引)用于在二级键上搜索文件,二级索引的搜索键指定了一个顺序,这个顺序与文件的排序顺序不同。

2、协处理器的特性是什么?

  • 允许用户执行region级的操作,使用类似触发器的功能
  • 允许扩展现有的RPC协议引入自己的调用
  • 提供一个非常灵活的、可用于建立分布式服务的数据模型
  • 能够自动化扩展、负载均衡、应用请求路由

3.协处理器的使用场景:

   维护辅助索引;维护数据间的应用完整性。

4.协处理器框架提供了两大类Observer、endPoint(以下是参考HBase权威指南第三版)

    通过继承这两大类来扩展自己的功能。

   1)Observer(观察者)

     该类是与RDMS中的触发器类似。回调函数在一些特定的事件发生时被调用。

     事件包括:用户产生的事件或者服务端内部产生的事件。

     协处理器框架提供的接口如下:

       a、RegionObserver:用户可以通过这种处理器来处理数据修改事件,它们与表的Region紧密关联。region级的操作。对应的操作是:put/delete/scan/get

       b、MasterObserver:可以用作管理或DDL类型的操作,是集群级的操作。对应的操作是:创建、删除、修改表。

       c、WALObserver:提供控制WAL的钩子函数。

      Observer定义好钩子函数,服务端可以调用。

   2)endPoint

    该类的功能类似RDMS中的存储过程。将用户的自定义操作添加到服务器端,endPoint可以通过添加远程过程调用来扩展RPC协议。用户可以将自定义完成某项操作代码部署到服务器端。例如:服务器端的计算操作。

    当二者结合使用可以决定服务器端的状态。

5、Coprocessor类

    所有的协处理器都必须实现给接口,该接口定义了协处理器的基本约定和易于框架管理,并且定义协处理器的执行的优先级别。

    1)协处理器的执行顺序

     Coprocessor.Priority枚举类型定义了两个值:SYSTEM、USER。前者优于后者执行,后者定义的按顺序执行。

    2)协处理器的生命周期

     协处理器的生命周期是由框架管理的,接口定义两个方法start、stop。这两个方法的参数是:CoprocessorEnvironment。该类提供了访问HBase的版本、Coprocessor版本、协处理器优先级等方法。start/stop方法是被隐式调用的,且关于协处理器的状态的定义是有一个枚举类Coprocessor.State对应的。

    3)协处理器环境和实例的维护

     CoprocessorHost类来完成,其有相应的子类来完成维护region、master协处理器的实例和环境。

    总结:Coprocessor、CoprocessorEnvironment、CoprocessorHost是三个类,在该三个类的基础上进行扩展功能,完成支持、管理、维护协处理器。

6、协处理器的加载/部署

     在加载处理器的方式上有两种方式:1.通过配置文件静态加载 2.在集群运行时动态加载(在权威指南第三版中指出尚未有动态加载的API)。

    1) 对于静态加载的方式

    在HBase权威指南中P171页指出,在此不再赘述,是搬砖的苦力活。其中需要强调的是书中“配置文件中配置项的顺序非常重要,这个顺序决定了执行顺序”

    2)特定表加载处理器是归属于静态加载的方式

        对于特定表的协处理器加载是通过表描述符。所以该处理器的加载只针对该表的region,同时被服务端的region和region server调用,不能被master或WAL调用。在HBase权威指南的P173给出示例。

7、RegionObserver类

      该类的描述:1.RegionObserver类是Observer类的子类2.明确是在响应region级别的操作。当region事件发生时,其定义的钩子函数被调用。该级别的操作可以分为两类:region生命周期变化或客户端API调用。

      1)处理region生命周期事件

       这里的生命周期事件体现的是region的状态变化,而触发器处理的时间发生在是状态变化的前、后。

       下面是不同的状态的前后可以定义的协处理器(这里的协处理器就是指可以进行的操作):

       状态1:pendingOpen,region将要被打开的状态。

        协处理器以实现的方法是:

       preOpen()/postOpen().完成功能是:搭载或者阻止这次打开过程。

       preWALRestore()/postWALRestore.完成的功能是:用户可以访问那些记录被修改了,监督那些记录被实施了。

       状态2:open,这个状态的标志是:region被部署到一个region server上且正常工作时。

       协处理器可以实现的方法是:

        void preFlush()/void postFlush()     内存被持久到磁盘

        void preSpilt()/void postSpilt()          region达到足够大时进行拆分

       状态3:pendingClose。region将要被关闭时的状态。

       协处理器可以实现的方法是:

       void preClose()/void postClose()

     2)处理客户端API事件

        这里是指在调用Java API 时,响应的事件。如:

        void prePut()/void postPut、void preDelete()/postDelete()、void preGet()/void postGet()........

     3)RegionCoprocessorEnvironment类

       实现RegionObserver类的协处理器环境类是基于RegionCoprocessorEnvironment类的,通过该类可以访问管理Region实例和共享RegionServerService实例

     4)ObserverContext

       RegionObserver类提供的所有回调函数都需要一个特殊的上下文作为共同参数。ObserverContext类提供了访问当前系统环境的入口,同时也添加一些关键功能用以通知协处理器框架在回到函数完成后需要做什么。讲解了byPass()/complete()方法,前者会停止当前服务进程处理过程,后者影响后面执行的协处理器。

     5)BaseRegionObserver类

       该类的作用是:可以作为实现所有监听类型协处理器的基类。需要注意的是要想实现自定义的功能必须重载这个类的方法。

8、MasterObserver类

     协处理器定义明确为master服务器的所有回调函数。这些回调函数中的操作是类似DDL,创建、删除、修改表。

    1)MasterCoprocessorEnvironment

         MasterCoprocessorEnvironment封装了MasterObserver实例,通过该类可以访问MasterService实例。

    2)BaseMasterServer

        BaseMasterServer是MasterServer的空实现,可以通过实现相应的pre/post来自定义相关操作。                        例如:  void preCreateTable()/void postCreateTable()  void preDeleteTable()/void postDeleteTable()......

9、endPoint

       提出endPoint原因?

        CoprocessorProtocol接口

       该接口可以使用户自定义RPC协议,它的实现代码被安装在服务端,在客户端HTable提供调用方法,使用该协议可以和协处理器实例之间通信。