hbase0.98.9中如何實現(xiàn)endpoints
本篇文章為大家展示了hbase0.98.9中如何實現(xiàn)endpoints，內(nèi)容簡明扼要并且容易理解，絕對能使你眼前一亮，通過這篇文章的詳細介紹希望你能有所收獲。
成都創(chuàng)新互聯(lián)專注于企業(yè)成都全網(wǎng)營銷推廣、網(wǎng)站重做改版、烏魯木齊網(wǎng)站定制設計、自適應品牌網(wǎng)站建設、H5建站、商城網(wǎng)站開發(fā)、集團公司官網(wǎng)建設、成都外貿(mào)網(wǎng)站建設、高端網(wǎng)站制作、響應式網(wǎng)頁設計等建站業(yè)務，價格優(yōu)惠性價比高，為烏魯木齊等各大城市提供網(wǎng)站開發(fā)制作服務。
定制一個endpoint的過程。
下面是實現(xiàn)過程：
1、定義接口描述文件（該功能有protobuf提供出來）
option java_package = "coprocessor.endpoints.generated";
option java_outer_classname = "RowCounterEndpointProtos";
option java_generic_services = true;
option java_generate_equals_and_hash = true;
option optimize_for = SPEED;
message CountRequest {
}
message CountResponse {
required int64 count = 1 [default = 0];
}
service RowCountService {
rpc getRowCount(CountRequest)
returns (CountResponse);
rpc getKeyValueCount(CountRequest)
returns (CountResponse);
}這個文件我直接拿的hbase提供的example中的例子。其中的語法應該有過類似經(jīng)驗的一看就清楚了，實在不清楚就請查查protobuf的幫助手冊吧。
2、根據(jù)接口描述文件生成java接口類（該功能有protobuf提供出來）
有了接口描述文件，還需要生成java語言的接口類。這個需要借助protobuf提供的工具protoc。
$protoc --java_out=./ Examples.proto
簡單解釋下，protoc這個命令在你裝了protobuf后就有了。Examples.proto這個是文件名，也就是剛才編寫的那個接口描述文件。“--java_out”這個用來指定生成后的java類放的地方。
所以，這地方如果你沒有裝protobuf，你需要裝一個，window和linux版都有，多說一句，如果你去裝hadoop64位的編譯環(huán)境的話，應該是要裝protobuf。
3、實現(xiàn)接口
package coprocessor;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import org.apache.hadoop.hbase.Cell;
import org.apache.hadoop.hbase.CellUtil;
import org.apache.hadoop.hbase.Coprocessor;
import org.apache.hadoop.hbase.CoprocessorEnvironment;
import org.apache.hadoop.hbase.client.Scan;
import org.apache.hadoop.hbase.coprocessor.CoprocessorException;
import org.apache.hadoop.hbase.coprocessor.CoprocessorService;
import org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment;
import org.apache.hadoop.hbase.filter.FirstKeyOnlyFilter;
import org.apache.hadoop.hbase.protobuf.ResponseConverter;
import org.apache.hadoop.hbase.regionserver.InternalScanner;
import org.apache.hadoop.hbase.util.Bytes;
import com.google.protobuf.RpcCallback;
import com.google.protobuf.RpcController;
import com.google.protobuf.Service;
import coprocessor.endpoints.generated.RowCounterEndpointProtos.CountRequest;
import coprocessor.endpoints.generated.RowCounterEndpointProtos.CountResponse;
import coprocessor.endpoints.generated.RowCounterEndpointProtos.RowCountService;
public class RowCounterEndpointExample extends RowCountService implements
Coprocessor, CoprocessorService {
private RegionCoprocessorEnvironment env;
public RowCounterEndpointExample() {
}
@Override
public Service getService() {
return this;
}
@Override
public void getRowCount(RpcController controller, CountRequest request,
RpcCallback<CountResponse> done) {
Scan scan = new Scan();
scan.setFilter(new FirstKeyOnlyFilter());
CountResponse response = null;
InternalScanner scanner = null;
try {
scanner = env.getRegion().getScanner(scan);
List<Cell> results = new ArrayList<Cell>();
boolean hasMore = false;
byte[] lastRow = null;
long count = 0;
do {
hasMore = scanner.next(results);
for (Cell kv : results) {
byte[] currentRow = CellUtil.cloneRow(kv);
if (lastRow == null || !Bytes.equals(lastRow, currentRow)) {
lastRow = currentRow;
count++;
}
}
results.clear();
} while (hasMore);
response = CountResponse.newBuilder().setCount(count).build();
} catch (IOException ioe) {
ResponseConverter.setControllerException(controller, ioe);
} finally {
if (scanner != null) {
try {
scanner.close();
} catch (IOException ignored) {
}
}
}
done.run(response);
}
@Override
public void getKeyValueCount(RpcController controller,
CountRequest request, RpcCallback<CountResponse> done) {
CountResponse response = null;
InternalScanner scanner = null;
try {
scanner = env.getRegion().getScanner(new Scan());
List<Cell> results = new ArrayList<Cell>();
boolean hasMore = false;
long count = 0;
do {
hasMore = scanner.next(results);
for (Cell kv : results) {
count++;
}
results.clear();
} while (hasMore);
response = CountResponse.newBuilder().setCount(count).build();
} catch (IOException ioe) {
ResponseConverter.setControllerException(controller, ioe);
} finally {
if (scanner != null) {
try {
scanner.close();
} catch (IOException ignored) {
}
}
}
done.run(response);
}
@Override
public void start(CoprocessorEnvironment env) throws IOException {
if (env instanceof RegionCoprocessorEnvironment) {
this.env = (RegionCoprocessorEnvironment) env;
} else {
throw new CoprocessorException("Must be loaded on a table region!");
}
}
@Override
public void stop(CoprocessorEnvironment env) throws IOException {
// TODO Auto-generated method stub
}
}4、注冊接口（Hbase功能，通過配置文件或者表模式方式注冊）
這部分，可以看hbase權威指南了，我就看這部分做的。
5、測試調(diào)用
package coprocessor;
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.client.HTable;
import org.apache.hadoop.hbase.client.coprocessor.Batch;
import org.apache.hadoop.hbase.ipc.BlockingRpcCallback;
import org.apache.hadoop.hbase.ipc.ServerRpcController;
import org.apache.hadoop.hbase.util.Bytes;
import com.google.protobuf.ServiceException;
import coprocessor.endpoints.generated.RowCounterEndpointProtos.CountRequest;
import coprocessor.endpoints.generated.RowCounterEndpointProtos.CountResponse;
import coprocessor.endpoints.generated.RowCounterEndpointProtos.RowCountService;
import util.HBaseHelper;
public class RowCounterEndpointClientExample {
public static void main(String[] args) throws ServiceException, Throwable {
Configuration conf = HBaseConfiguration.create();
HBaseHelper helper = HBaseHelper.getHelper(conf);
//helper.dropTable("testtable");
//helper.createTable("testtable", "colfam1", "colfam2");
System.out.println("Adding rows to table...");
helper.fillTable("testtable", 1, 10, 10, "colfam1", "colfam2");
HTable table = new HTable(conf, "testtable");
final CountRequest request = CountRequest.getDefaultInstance();
final Batch.Call<RowCountService, Long> call =new Batch.Call<RowCountService, Long>() {
public Long call(RowCountService counter)
throws IOException {
ServerRpcController controller = new ServerRpcController();
BlockingRpcCallback<CountResponse> rpcCallback = new BlockingRpcCallback<CountResponse>();
counter.getRowCount(controller, request, rpcCallback);
CountResponse response = rpcCallback.get();
if (controller.failedOnException()) {
throw controller.getFailedOn();
}
return (response != null && response.hasCount()) ? response
.getCount() : 0;
}
};
Map<byte[], Long> results = table.coprocessorService(
RowCountService.class, null, null, call);
for(byte[] b : results.keySet()){
System.err.println(Bytes.toString(b) + ":" + results.get(b));
}
}
}上述內(nèi)容就是hbase0.98.9中如何實現(xiàn)endpoints，你們學到知識或技能了嗎？如果還想學到更多技能或者豐富自己的知識儲備，歡迎關注創(chuàng)新互聯(lián)行業(yè)資訊頻道。
網(wǎng)站欄目：hbase0.98.9中如何實現(xiàn)endpoints
網(wǎng)站網(wǎng)址：http://muchs.cn/article40/gepheo.html
成都網(wǎng)站建設公司_創(chuàng)新互聯(lián)，為您提供電子商務、品牌網(wǎng)站設計、網(wǎng)站營銷、網(wǎng)站建設、建站公司、品牌網(wǎng)站建設
聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉載內(nèi)容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉載，或轉載時需注明來源： 創(chuàng)新互聯(lián)
- 成都網(wǎng)站建設中搜索引擎優(yōu)化怎么做 2016-10-29
- 中小型企業(yè)網(wǎng)站的搜索引擎優(yōu)化通病 2021-08-27
- CMS建站系統(tǒng)在搜索引擎優(yōu)化中有哪些優(yōu)勢？ 2016-11-22
- 搜索引擎優(yōu)化必知的SEO知識 2021-06-11
- 什么是SEO(搜索引擎優(yōu)化)?我認為的SEO是這樣的 2015-05-18
- 北京網(wǎng)站建設企業(yè)網(wǎng)站搜索引擎優(yōu)化中相關知識 2021-05-24
- 企業(yè)網(wǎng)站建設推廣中搜索引擎優(yōu)化策略 2020-11-13
- seo搜索引擎優(yōu)化工作需要 2014-05-02
- 網(wǎng)站建設中搜索引擎優(yōu)化需要注意的事項及建議 2014-07-23
- 淺談：搜索引擎優(yōu)化的過程 2015-11-03
- 淺談網(wǎng)站搜索引擎優(yōu)化的新規(guī)則 2022-07-13
- 網(wǎng)站站群的搜索引擎優(yōu)化方法 2017-02-12