// 建立表：
create 'guanzhu','cf1'
create 'fensi','cf1'
// 測試插入資料
put 'guanzhu','g','cf1:from','j'
put 'fensi','b','cf1:from','a'
// 上傳jar包到hdfs
hadoop fs -mkdir /input
hadoop fs -put myhbase.jar /input
hadoop fs -rm -r /input/myhbase.jar
hadoop fs -put sdfjlkjkldsjfkl
// 給guanzhu表新增coprocessor
disable 'guanzhu'
alter'guanzhu',method =>'table_att','coprocessor' =>'hdfs://myha01/input/myhbase.jar|com.ghgj.hbase.coprocessor.indexobserver|100|'
enable 'guanzhu'
// 給guanzhu表移除coprocessor
disable 'guanzhu'
alter 'guanzhu',method=>'table_att_unset',name=>'coprocessor$1'
enable 'guanzhu'
// 查詢兩張表資料
scan 'guanzhu'
scan 'fensi'
// 刪除兩張表
disable 'guanzhu'
drop 'guanzhu'
disable 'fensi'
drop 'fensi'
// 檢視表結構
desc 'guanzhu'
desc 'fensi'
// 建立表：
create 'mystu','base'
// 插入資料
put 'mystu','rk001','base:name','huangbo'
put 'mystu','rk002','base:name','xuzheng'
put 'mystu','rk003','base:name','wangbaoqiang'
put 'mystu','rk004','base:name','huangxiaoming'
// 上傳jar包
hadoop fs -mkdir /input1
hadoop fs -put myhbase.jar /input1
hadoop fs -rm -r /input1/myhbase.jar
// 新增協處理器
disable 'mystu'
alter 'mystu',method =>'table_att','coprocessor' =>'hdfs://myha01/input1/myhbase.jar|com.ghgj.hbase.coprocessor.endpoint.sumendpoint|1001|'
enable 'mystu'
// 刪除表
disable 'mystu'
drop 'mystu'
// 檢視表結構
desc 'mystu'
// 檢視表資料
scan 'mystu'
hbase 協處理器 部署 hbase 協處理器
1 自定義協處理器 hbase 版本 2.x 使用自定義的協處理器需要實現coprocessor,regionobserver,coprocessorservice這三個介面，如下圖 可以看出協處理器的載入分為靜態載入和動態載入，靜態載入需要修改hbase site.xml配置檔案，這將對所有的hb...
HBase協處理器
協處理器分兩種型別，系統協處理器可以全域性匯入region server上的所有資料表，表協處理器即是使用者可以指定一張表使用協處理器。協處理器框架為了更好支援其行為的靈活性，提供了兩個不同方面的外掛程式。乙個是觀察者 observer 類似於關聯式資料庫的觸發器。另乙個是終端 endpoint 動...
Hbase協處理器
hbase作為資料庫最經常被人詬病的特性包括 無法輕易建立 二級索引 難以求和 計數 排序等操作 比如，在舊版本的 0.92 hbase中，統計資料表的行數，需要使用counter方法，執行一次mapreduce job 才能得到。雖然hbase在資料儲存層中整合了mapreduce，能夠有效用於資...