当前访客身份:游客 [ 登录  | 注册加入尚学堂]
直播

我来了!

拥有积分:4038
尚学堂雄起!!威武。。。

博客分类

笔记中心

课题中心

提问中心

答题中心

解答题中心

HBase之Java API

我来了! 发表于 2年前 (2014-11-12 15:35:26)  |  评论(0)  |  阅读次数(341)| 0 人收藏此文章,   我要收藏   

1.Configuration

在使用Java API时,Client端需要知道HBase的配置环境,如存储地址,zookeeper等信息。这些信息通过Configuration对象来封装,可通过如下代码构建该对象

        Configuration config=HBaseConfiguration.create();

在调用HBaseConfiguration.create()方法时,HBase首先会在classpath下查找hbase-site.xml文件,将里面的信息解析出来封装到Configuration对象中,如果hbase-site.xml文件不存在,则使用默认的hbase-core.xml文件。

除了将hbase-site.xml放到classpath下,开发人员还可通过config.set(name, value)方法来手工构建Configuration对象。

        Configuration.set(String name, String value)

2.HBaseAdmin

HBaseAdmin用于创建数据库表格,并管理表格的元数据信息,通过如下方法构建

        HBaseAdmin admin=new HBaseAdmin(config);

常用方法:

        addColumn(tableName,column):为表格添加栏位

        deleteColumn(tableName,column):删除指定栏位

        balanceSwitch(boolean):是否启用负载均衡

        createTable(HTableDescriptor desc):创建表格

        deleteTable(tableName):删除表格

        tableExists(tableName):判断表格是否存在

示例:创建test表格,并为其指定columnFamily为cf

HBaseAdmin admin=new HBaseAdmin(config);
If(!admin.tableExists(“test”)){
	HTableDescriptor tableDesc=new HTableDescriptor(“test”);
	HColumnDescriptor cf=new HColumnDescriptor(“cf”);
	tableDesc.addFamily(cf);
	admin.createTable(tableDesc);
}

3.HTable

在HBase中,HTable封装表格对象,对表格的增删改查操作主要通过它来完成,构造方法如下:

        HTable table=new HTable(config,tableName);

在构建多个HTable对象时,HBase推荐所有的HTable使用同一个Configuration。这样,HTable之间便可共享HConnection对象、zookeeper信息以及Region地址的缓存信息。

示例1:Get操作

Get get=new Get(rowKey);
Result res=table.get(get);
示例2:Put操作

Put put=new Put(rowKey);
put.add(columnFamily,column,value);
table.put(put);
注:在HBase中,实体的新增和更新都是通过Put操作来实现。

示例3:Delete操作

Delete delete=new Delete();
table.delete(delete);
示例4:Scan操作

Scan scan=new Scan( );
scan.addColumn(columnFamily,column);//指定查询要返回的column
SingleColumnValueFilter filter=new SingleColumnValueFilter(
        columnFamily,column,//指定要过滤的column
        CompareOp.EQUAL,value//指定过滤条件
);
//更多的过滤器信息请查看org.apache.hadoop.hbase.filter包
scan.setFilter(filter);//为查询指定过滤器
ResultScanner scanner=table.getScanner(scan);//执行扫描查找
Iterator<Result> res=scanner.iterator( );//返回查询遍历器


分享到:0
关注微信,跟着我们扩展技术视野。每天推送IT新技术文章,每周聚焦一门新技术。微信二维码如下:
微信公众账号:尚学堂(微信号:bjsxt-java)
声明:博客文章版权属于原创作者,受法律保护。如果侵犯了您的权利,请联系管理员,我们将及时删除!
(邮箱:webmaster#sxt.cn(#换为@))
北京总部地址:北京市海淀区西三旗桥东建材城西路85号神州科技园B座三层尚学堂 咨询电话:400-009-1906 010-56233821
Copyright 2007-2015 北京尚学堂科技有限公司 京ICP备13018289号-1 京公网安备11010802015183