c语言清空文件中数据 HBase的协处理器开发编码实例(7)

》enable ‘sum_table’

// 如果要卸载协处理器，可以先查看表中协处理器名，然后通过命令卸载

》disable ‘sum_table’

》 describe‘sum_table’

》 alter‘sum_table’，METHOD =》‘table_att_unset’，NAME=》‘coprocessor$1’

》 enable‘sum_table’

4.4 测试

在eclipse中运行客户端程序SumClient，输出结果为193，正好符合预期，如下图所示：

5 Observer编码示例

一般来说，对建立索引，往往需要单独的数据结构来存储索引的数据。在hbase表中，除了使用rowkey索引数据外，还可以另外建立一张索引表，查询时先查询索引表，然后用查询结果查询数据表。下面这个示例演示如何使用Observer协处理器生成HBase表的二级索引：将数据表ob_table中列info:name的值作为索引表index_ob_table的rowkey，将数据表ob_table中列info:score的值作为索引表index_ob_table中列info:score的值建立二级索引，当用户向数据表中插入数据时，索引表将自动插入二级索引，从而为查询业务数据提供了便利。

5.1 代码

在项目中新建类PutObserver作为Observer协处理器应用逻辑类，代码如下：

〔java〕 view plain copypackage com.hbase.demo.observer;

import java.io.IOException;

import java.util.List;

import org.apache.hadoop.hbase.Cell;

import org.apache.hadoop.hbase.CellUtil;

import org.apache.hadoop.hbase.TableName;

import org.apache.hadoop.hbase.client.Durability;

import org.apache.hadoop.hbase.client.HTableInterface;

import org.apache.hadoop.hbase.client.Put;

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.regionserver.wal.WALEdit;

import org.apache.hadoop.hbase.util.Bytes;

/**

* @author developer

* 说明：hbase协处理器observer的应用逻辑代码

* 功能：在应用了该observer的hbase表中，所有的put操作，都会将每行数据的info:name列值作为rowkey、info:score列值作为value

本文来自电脑杂谈，转载请注明本文网址：
http://www.pc-fly.com/a/jisuanjixue/article-59353-7.html