异步hbase包asynchbase-1.4.1.jar,maven的pom如下:
<dependency>
<groupId>org.hbase</groupId>
<artifactId>asynchbase</artifactId>
<version>1.4.1</version>
</dependency>
HBaseClient client = new HBaseClient("test036083.sqa.cm4.tbsite.net");
//生成一个PutRequest对象
byte[][] qualifiers = new byte[kvs.size()][];
byte[][] values = new byte[kvs.size()][];
PutRequest put = new PutRequest("table-name".getBytes(), "kv".getBytes(), "columnFamily".getBytes(), qualifiers, values, System.currentTimeMillis())
//异步写入
Deferred<Object> d= client.put(put);
d.addErrback(new Callback<Object, Exception> {
@Override
public Object call(final Exception arg) {
if (arg instanceof PleaseThrottleException) {
final PleaseThrottleException e = (PleaseThrottleException) arg;
LOG.warn("Need to throttle, HBase isn't keeping up.", e);
throttle = true;
final HBaseRpc rpc = e.getFailedRpc();
if (rpc instanceof PutRequest) {
client.put((PutRequest) rpc); // Don't lose edits.
}
return null;
}
return arg;
}
@Override
public String toString() {
return "importFile errback";
});
Deferred类似于JDK中的异步线程返回对象Future,这里加了个Callback对象是当Deferred为available时且是一个异常,就会执行加入的Callback对象。
异步hbase大大提供了大数据量下hbase的写入性能,是一个不错的优化点~
相关推荐
Hbase shell 、Hbase api、Hbase 配置
java 利用 sping-data-hadoop HbaseTemplate 操作hbase find get execute 等方法 可以直接运行
HBase shell的基本用法
node-hbase-client 是 Node.js 的异步 HBase 客户端,使用纯 JavaScript 实现。当前状态:完全通过 HBase 0.94 和 0.94.16Java hbase-client支持 HBase 服务器的版本[√] 0.94.x[√] 0.94.0[√] 0.94.160.95.x0.96.x...
搭建pinpoint需要的hbase初始化脚本hbase-create.hbase
Hbase图形化客户端工具,squirrel使用Phoenix连接HBASE附带使用方法,还有hive,pig等jar包
5 5)最后,HBase不支持联合查询 5 mapreduce与HBase表配合使用 5 4. HBase的模式Schema设计的一些概念和原则 5 1)模式的创建与更新 5 2)列族的数量 6 3)行键设计RowKey 6 5. HBase的拓扑结构是什么? 7 1)拓扑...
HBase(hbase-2.4.9-bin.tar.gz)是一个分布式的、面向列的开源数据库,该技术来源于 Fay Chang 所撰写的Google论文“Bigtable:一个结构化数据的分布式存储系统”。就像Bigtable利用了Google文件系统(File System...
Hbase图形化客户端工具,squirrel使用Phoenix连接HBASE附带使用方法,和之前的一个part1,一起使用
HBase开发实战,HBase学习利器:HBase实战
HBase 官方文档.pdf HBase的操作和编程.pdf HBase Cpressr优化与实验 郭磊涛.pdf null【HBase】Data Migratin frm Gri t Clu Cmputing - Natural Sienes .pdf 分布式数据库HBase快照的设计与实现.pdf 【HBase】...
此自述文件为您提供了在opentsdb安装的顶部添加accumulo-opentsdb的步骤的概述,以将时间序列数据而不是HBase放入accumulo。 依赖 在添加此补丁之前,我们假设您已经安装了以下软件: Maven 3.1.0(有关下载和安装...
对HBase的API做了一层抽象,统一了HBase1.x和HBase2.x的实现,并提供了读写HBase的ORM的支持,同时,sdk还对HBase thrift 的客户端API进行了池化封装,(类似JedisPool),消除了直接使用原生API的各种问题,使之...
HBase开启审计日志
NULL 博文链接:https://whxhz.iteye.com/blog/1607834
1. 请用java集合的代码描述HBase的表结构 2. 请简述HBase中数据写入最后导致Region分裂的全过程 3. 如果设计一个笔记的表,表中要求有笔记的属性和笔记的内容,怎么做 4. HBase部署时如何指定多个zookeeper 5. HBase...
HBASE
说明:使用外部zookeeper3.4.13之hbase2.3.5一键部署工具,支持部署、启动、停止、清除、连接,支持自定义服务端口,数据存储目录等功能,已在生产环境使用。 Options: deploy.sh build single 构建并启动一个hbase...
HBase3.0参考指南 This is the official reference guide for the HBase version it ships with. Herein you will find either the definitive documentation on an HBase topic as of its standing when the ...
hbase 资源合集 hbase 企业应用开发实战 权威指南 hbase 实战 hbase 应用架构