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

}

}

// 协处理器结束时调用的方法

@Override

public void stop（CoprocessorEnvironment env） throws IOException {

}

}

4.2 客户端代码

在项目中新建类SumClient作为调用RPC服务的客户端测试程序，代码如下：

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

import java.io.IOException;

import java.util.Map;

import org.apache.hadoop.conf.Configuration;

import org.apache.hadoop.hbase.HBaseConfiguration;

import org.apache.hadoop.hbase.TableName;

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

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

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

import org.apache.hadoop.hbase.client.coprocessor.Batch;

import org.apache.hadoop.hbase.ipc.BlockingRpcCallback;

import com.google.protobuf.ServiceException;

import com.hbase.demo.endpoint.Sum.SumRequest;

import com.hbase.demo.endpoint.Sum.SumResponse;

import com.hbase.demo.endpoint.Sum.SumService;

/**

* @author developer

* 说明：hbase协处理器endpooint的客户端代码

* 功能：从服务端获取对hbase表指定列的数据的求和结果

*/

public class SumClient {

public static void main（String〔〕 args） throws ServiceException， Throwable {

long sum = 0L;

// 配置HBse

Configuration conf = HBaseConfiguration.create（）;

conf.set（“hbase.zookeeper.quorum”， “localhost”）;

conf.set（“hbase.zookeeper.property.clientPort”， “2222”）;

// 建立一个的连接

Connection conn = ConnectionFactory.createConnection（conf）;

// 获取表

HTable table = （HTable） conn.getTable（TableName.valueOf（“sum_table”））;

// 设置请求对象

final SumRequest request = SumRequest.newBuilder（）.setFamily（“info”）.setColumn（“score”）.build（）;

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