Java代码通过API操作HBase的最佳实践
更新时间:2024-04-08 00:56:01 阅读量: 综合文库 文档下载
Java代码通过API操作HBase的最佳实践
HBase提供了丰富的API。这使得用Java连接HBase非常方便。
有时候大家会使用HTable table=new HTable(config,tablename);的方式来实例化一个HTable对象,实际上这并不是最好的实例化HTable的办法。最好的办法是使用HTablePool,并且每个线程都使用独立的HTable(参见《HBase The Definitive Guide》 4.4 HtablePool 和3.1 客户端API 概述)。因为HTable实例的创建非常耗时,需要扫描.META表确认表是否存在,是否可用等,还需要做其他的一些操作,所以,最好在系统启动的时候创建实例,如果需要多个HTable,考虑使用HTablePool。 比如我在webservice中,需要对HTable进行查询,并将数据返回,我是这么做的: 可以在提供服务的类的构造函数里完成HTablePool的初始化,弃用下面的方法。
先在静态代码块中把系统中需要用到的表都获取一遍,获取完之后立即关闭该表,以期增加真正的服务的代码中,第一次实例化HTable对象的效率。
//这是我对外提供服务的类 public class HBaseQu {
// SignHBase.getConfiguration()是从配置文件中获取 //org.apache.hadoop.conf.Configuration的一个对象 // 定义一个全局的HTablePool
public static HTablePool hTablePool = new HTablePool( SignHBase.getConfiguration(), Integer.MAX_VALUE);
// 初始化所用到的HTablePool,从pool中get一个需要用到的表,get完毕,立即关闭,
// 以后每增加一个接口,如果需要用到一个新表的话,就在此处增加一次获取表,然后关闭它的代码。 static {
HTable table = null;
//从池里获取一个表,然后关闭它(类似于充血) try { table = (HTable) hTablePool.getTable(tableName); if (null != table) {
table.close(); } }
catch (IOException e) {
e.printStackTrace(); }
//获取另外一个表
try {
table = (HTable) hTablePool.getTable(tableName2); if (null != table) {
table.close(); } }
catch (IOException e) {
e.printStackTrace(); } } }
在真正的服务的代码中,直接使用pool.getTable(tableName)即可快速实例化该表。如下所示:
HTable table = null;//定义HTable
ResultScanner rs = null;//定义接收结果的ResultScanner对象 try {
//实例化HTable对象
table = (HTable) HBaseQu.hTablePool.getTable(tablename); Scan s = new Scan();//实例化Scan对象
s.setFilter(new PrefixFilter(rowPrifix.getBytes()));//添加过滤器
s.addColumn(Bytes.toBytes(family), Bytes.toBytes(qualifier));
rs = table.getScanner(s);//获取结果 for (Result r : rs) {//循环处理行
KeyValue[] kv = r.raw();
for (int i = 0; i < kv.length; i++) {
value.add(new String(kv[i].getRow(), \\
+ new String(kv[i].getFamily()) + \ + new String(kv[i].getQualifier()) + \
+ new String(kv[i].getValue()));
} } }
catch (Exception e) {
e.printStackTrace(); return null; }
finally {
//关闭打开的资源 if (null != rs) {
rs.close(); } try {
if (null != table) {
table.close(); } }
catch (IOException e) {
e.printStackTrace(); } }
- 多层物业服务方案
- (审判实务)习惯法与少数民族地区民间纠纷解决问题(孙 潋)
- 人教版新课标六年级下册语文全册教案
- 词语打卡
- photoshop实习报告
- 钢结构设计原理综合测试2
- 2014年期末练习题
- 高中数学中的逆向思维解题方法探讨
- 名师原创 全国通用2014-2015学年高二寒假作业 政治(一)Word版
- 北航《建筑结构检测鉴定与加固》在线作业三
- XX县卫生监督所工程建设项目可行性研究报告
- 小学四年级观察作文经典评语
- 浅谈110KV变电站电气一次设计-程泉焱(1)
- 安全员考试题库
- 国家电网公司变电运维管理规定(试行)
- 义务教育课程标准稿征求意见提纲
- 教学秘书面试技巧
- 钢结构工程施工组织设计
- 水利工程概论论文
- 09届九年级数学第四次模拟试卷
- 实践
- 最佳
- 通过
- 代码
- 操作
- HBase
- Java
- API
- 2016-2020年中国报废汽车回收拆解行业深度调研及投资前景预测报
- 首师大古代文学考研真题之中国语言文学(2007)
- 泰州市公推公选市管领导干部简章
- 吊篮围栏安装技术交底
- 做好学校食堂米面肉等大宗食品统一采购工作的通知的 …
- 浙江工业大学机械原理第八章习题第十章习题
- 2014年北师大三年级下册数学第二单元组卷(含答案)
- 农民专业合作社章程doc
- 2020版高考数学复习专题9平面解析几何第73练抛物线文
- 中国社会思想史期中作业
- 2014安全管理制度宣贯培训考试题库-大连化物所
- 江苏省苏州市2009届高三教学调研测试
- 水泥混凝土桥面防水的发展 - 图文
- 青岛版科学四年级下册课堂练习题及答案 - 图文
- 北京同仁堂股份有限公司财务评价—本科毕业设计论文(1)
- 六年级语文统筹方法
- 2012北京市丰台区2012年高三二模(理科)数学试题及答案
- 2016年执法资格考试模拟试卷
- 部编西师版二年级上册语文全册教案
- 2012年浙江省衢州市企业技术难题和需求 - 图文