赞
踩
任务描述
本关任务:使用Java
代码在HBase
中创建表。
为了完成本关任务,你需要掌握:
1.如何使用Java
连接HBase
数据库,
2.如何使用Java
代码在HBase
中创建表。
如何使用Java连接HBase数据库
Java
连接HBase
需要两个类:
HBaseConfiguration
ConnectionFactory
HBaseConfiguration
要连接HBase
我们首先需要创建Configuration
对象,这个对象我们需要通过HBaseConfiguration
(HBase
配置)对象来进行创建,HBaseConfiguration
看名字我们就能猜到它的用途:读取指定路径下hbase-site.xml
和hbase-default.xml
的配置信息。
具体用法:
Configuration config = HBaseConfiguration.create(); //使用create()静态方法就可以得到Configuration对象
ConnectionFactory
获取到连接对象Connextion
我们就算连接上了HBase
了,怎么获取呢?
通过ConnectionFactory
(连接工厂)的方法我们就能获取到Connection
(连接对象)了。
具体用法:
Connection connection = ConnectionFactory.createConnection(config); //config为前文的配置对象
使用这两个步骤就能完成连接HBase
了。
注意:在1.0之前的版本
HBase
是使用HBaseAdmin
和HTable
等来操作HBase
的,但是在1.0
之后的版本中这些被弃用了,新的客户端API
更加干净简洁,本文使用的HBase
是2.1.1
版本(18年10月发布)的,
创建表
要创建表我们需要首先创建一个Admin
对象,然后让它来创建一张表:
- Admin admin = connection.getAdmin(); //使用连接对象获取Admin对象
- TableName tableName = TableName.valueOf("test");//定义表名
- HTableDescriptor htd = new HTableDescriptor(tableName);//定义表对象
- HColumnDescriptor hcd = new HColumnDescriptor("data");//定义列族对象
- htd.addFamily(hcd); //添加
- admin.createTable(htd);//创建表
HBase2.X创建表
上述创建表的方法是HBase1.X
版本的方式,而在HBase2.X
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。