HBase協(xié)處理器加載的方式有哪些

這篇文章主要介紹“HBase協(xié)處理器加載的方式有哪些”，在日常操作中，相信很多人在HBase協(xié)處理器加載的方式有哪些問題上存在疑惑，小編查閱了各式資料，整理出簡單好用的操作方法，希望對(duì)大家解答”HBase協(xié)處理器加載的方式有哪些”的疑惑有所幫助！接下來，請(qǐng)跟著小編一起來學(xué)習(xí)吧！

HBase協(xié)處理器加載的三種方式

Shell加載

1. 上傳HDFS

將打包好的HelloCoprocessor-0.0.1.jar上傳服務(wù)器，然后放到HDFS上。

# 切換hadoop用戶，創(chuàng)建演示目錄

$ hdfs dfs -mkdir /usr/hbase/coprocessor

$ hdfs dfs -put HelloCoprocessor-0.0.1.jar /usr/hbase/coprocessor

2. Shell 加載協(xié)處理器

我們假設(shè)其協(xié)處理器類的包名為：

org.myname.hbase.Coprocessor.RegionObserverExample

Shell 操作如下：

hbase> disable 'mytable' # 禁用表，可選

hbase> alter 'mytable', METHOD => 'table_att', 'coprocessor' => '/usr/hbase/coprocessor/HelloCoprocessor-0.0.1.jar'|org.myname.hbase.Coprocessor.RegionObserverExample|1001|arg1=1,arg2=2'

hbase> enable 'mytable' # 禁用表后啟用表，可選

結(jié)構(gòu)如下：

hbase> alter 'mytable', METHOD => 'table_att', 'coprocessor' => ①|(zhì)②|③|④'  

解釋下上面各個(gè)參數(shù)：

①：協(xié)處理器Jar包路徑，要保證所有的RegionServer可讀取到。也可以是本地路徑，不過建議是放在HDFS上。

②：協(xié)處理器的完整類名。

③：協(xié)處理器優(yōu)先級(jí)，整數(shù)表示。可以為空。

④：傳遞給協(xié)處理器的參數(shù)，可以為空。

注：各參數(shù)間不要有空格。

3. 驗(yàn)證是否加載協(xié)處理器

hbase> desc 'mytable'

Table mytable is ENABLE

mytable, {TABLE_ATTRIBUTES => {coprocessor$1 => '/usr/hbase/coprocessor/HelloCoprocessor-0.0.1.jar'|org.myname.hbase.Coprocessor.RegionObserverExample|1001|arg1=1,arg2=2'}}

此驗(yàn)證不保證協(xié)處理器能正常工作：shell命令既不保證特定位置存在jar文件，也不驗(yàn)證給定類是否實(shí)際包含在jar文件中。

4. 卸載協(xié)處理器

hbase> disable 'mytable' # 禁用表，可選

hbase> alter 'mytable', METHOD => 'table_att_unset', NAME => 'coprocessor$1'

hbase> enable 'mytable' # 禁用表后啟用表，可選

坑：在沒有重啟HBase情況下，如果修改協(xié)處理器代碼并重新加載協(xié)處理器，請(qǐng)重命名協(xié)處理器Jar包的名字，否則不會(huì)生效。（由于當(dāng)前JVM引用了現(xiàn)有的協(xié)處理器，因此必須通過重新啟動(dòng)RegionServer來重新啟動(dòng)JVM，以便替換它。）

Api 加載

具體方法是調(diào)用HtableDescriptor的addCoprocessor方法。該方法有兩個(gè)重載方法：

addCoprocessor(String className)

addCoprocessor(className,jarPath,priority,kvs)

第二個(gè)重載方法提供了上述Shell中所需的各個(gè)參數(shù)①②③④，方法一則需要用戶手動(dòng)將jar包分發(fā)到各個(gè)RegionServer的lib目錄下。

示例代碼如下：

TableName tableName = TableName.valueOf("mytable");

Path path = new Path("hdfs://<namenode>:<port>/usr/hbase/coprocessor/HelloCoprocessor-0.0.1.jar");

Configuration conf = HBaseConfiguration.create();

Connection connection = ConnectionFactory.createConnection(conf);

Admin admin = connection.getAdmin();

admin.disableTable(tableName);

HTableDescriptor hTableDescriptor = new HTableDescriptor(tableName);

HColumnDescriptor columnFamily1 = new HColumnDescriptor("f1");

columnFamily1.setMaxVersions(1);

hTableDescriptor.addFamily(columnFamily1);

HColumnDescriptor columnFamily2 = new HColumnDescriptor("f2");

columnFamily2.setMaxVersions(3);

hTableDescriptor.addFamily(columnFamily2);

hTableDescriptor.addCoprocessor('org.myname.hbase.Coprocessor.RegionObserverExample', path,

Coprocessor.PRIORITY_USER, null);

admin.modifyTable(tableName, hTableDescriptor);

admin.enableTable(tableName);

重新加載表定義，無需使用addCoprocessor()方法設(shè)置協(xié)處理器的值。這將刪除附加到表的任何協(xié)處理器。

配置文件加載

1. 修改配置文件：hbase-site.xml，配置項(xiàng)如下：

1.1 RegionObservers/Endpoints

<property>

    <name>hbase.coprocessor.region.classes</name>

    <value>org.myname.hbase.Coprocessor.RegionObserverExample</value>

</property>

1.2 WALObservers

<property>

    <name>hbase.coprocessor.wal.classes</name>

    <value>org.myname.hbase.Coprocessor.RegionObserverExample</value>

</property>

1.3 MasterObservers

<property>

    <name>hbase.coprocessor.master.classes</name>

    <value>org.myname.hbase.Coprocessor.RegionObserverExample</value>

</property>

如果想同時(shí)配置多個(gè)協(xié)處理器，可以用逗號(hào)分隔多個(gè)協(xié)處理器的類名。

2. 添加Jar包

將您的代碼放在HBase的類路徑上。一種簡單的方法是將jar（包含代碼和所有依賴項(xiàng)）放入HBase的安裝目錄lib/中。

3. 重啟HBase生效。

4. 靜態(tài)卸載

從hbase-site.xml中刪除協(xié)處理器的元素，包括子元素。

重啟HBase。

從類路徑或HBase的lib/目錄中刪除協(xié)處理器的JAR文件。（可選）

到此，關(guān)于“HBase協(xié)處理器加載的方式有哪些”的學(xué)習(xí)就結(jié)束了，希望能夠解決大家的疑惑。理論與實(shí)踐的搭配能更好的幫助大家學(xué)習(xí)，快去試試吧！若想繼續(xù)學(xué)習(xí)更多相關(guān)知識(shí)，請(qǐng)繼續(xù)關(guān)注億速云網(wǎng)站，小編會(huì)繼續(xù)努力為大家?guī)砀鄬?shí)用的文章！