Hbase協處理器coprocessor

對每個region進行處理，彌補了scan的時候有限的幾個過濾器的不足

分為兩種類型

1. observer 觀察者相當于觸發器
   

2. Endpoint終端相當于存儲過程

下面的觀察者實現查詢之前替換掉行鍵為Jack的KeyValue

import java.io.IOException;
import java.util.List;

import org.apache.hadoop.hbase.KeyValue;
import org.apache.hadoop.hbase.client.Get;
import org.apache.hadoop.hbase.coprocessor.BaseRegionObserver;
import org.apache.hadoop.hbase.coprocessor.ObserverContext;
import org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment;
import org.apache.hadoop.hbase.util.Bytes;

public class RegionObserverTest extends BaseRegionObserver {
    private static byte[] fixed_rowkey = "Jack".getBytes();

    @Override
    public void postGet(ObserverContext<RegionCoprocessorEnvironment> c,
            Get get, List<KeyValue> result) throws IOException {
        if (Bytes.equals(get.getRow(), fixed_rowkey)) {

            KeyValue kv = new KeyValue(get.getRow(), Bytes.toBytes("time"),
                    Bytes.toBytes("time"), Bytes.toBytes(System
                            .currentTimeMillis()));
            result.add(kv);
        }
    }

}

加載協處理器命令

disable 'students'
alter 'students' ,'coprocessor'=>'hdfs://ns1/coprocessor.jar|com.hbase.RegionObserverTest||'
enable 'students'

alter 'table_name' ,METHOD=>'table_att', 'coprocessor'=>'path|class|number|args'

number表示第幾個協處理器

刪除第一個協處理器

alter 'table_name' ,METHOD=>'table_att_unset',NAME=>'coprocessor$1'