您好,欢迎访问一九零五行业门户网

Java在HBase数据库创建表

要通过java在hbase中创建一个数据表,首先需要导入hbase-client.jar驱动包。可以在项目pom.xml配置文件中添加依赖:
要通过java在hbase中创建一个数据表,首先需要导入hbase-client.jar驱动包。可以在项目pom.xml配置文件中添加依赖:
org.apache.hbasehbase-client1.1.0.1在添加依赖后,我们需要创建configuration对象,并指定core-site.xml和hbase-site.xml作为资源文件。
configuration config = hbaseconfiguration.create();config.addresource(new path(/etc/hbase/conf/hbase-site.xml));config.addresource(new path(/etc/hadoop/conf/core-site.xml));还需要在configuration对象中设置hbase.zookeeper.quorum参数和hbase.zookeeper.property.clientport参数的值,这些值也可以在hbase-site.xml配置文件中找到:
configuration config = hbaseconfiguration.create();config.set(hbase.zookeeper.quorum, 127.0.0.1);config.set(hbase.zookeeper.property.clientport, 2181);configuration对象创建完成后,接着创建连接到hbase数据库的connection对象,并通过此对象获取admin对象,它负责实现创建数据表的操作:
connection connection = connectionfactory.createconnection(config);admin admin = connection.getadmin();一旦创建了admin对象后,可以通过下面的代码创建数据表了:
string tablename = users;if (!admin.istableavailable(tablename.valueof(tablename))) {htabledescriptor hbasetable = new htabledescriptor(tablename.valueof(tablename));hbasetable.addfamily(new hcolumndescriptor(name));hbasetable.addfamily(new hcolumndescriptor(contact_info));hbasetable.addfamily(new hcolumndescriptor(personal_info));admin.createtable(hbasetable);}会严重是否存在“users”名的数据表,如果此表不存在就会创建一个新表,,列名包括:家庭名、联系信息和个人信息。
完整的程序如下:
package com.wordpress.khodeprasad;import org.apache.hadoop.conf.configuration;import org.apache.hadoop.hbase.hbaseconfiguration;import org.apache.hadoop.hbase.hcolumndescriptor;import org.apache.hadoop.hbase.htabledescriptor;import org.apache.hadoop.hbase.tablename;import org.apache.hadoop.hbase.client.admin;import org.apache.hadoop.hbase.client.connection;import org.apache.hadoop.hbase.client.connectionfactory;/*** @author prasad khode**/public class createtable {public static void main(string[] args) {createtable object = new createtable();object.createtable();}public void createtable() {configuration config = hbaseconfiguration.create();config.set(hbase.zookeeper.quorum, 127.0.0.1);config.set(hbase.zookeeper.property.clientport, 2181);connection connection = null;admin admin = null;try {connection = connectionfactory.createconnection(config);admin = connection.getadmin();string tablename = users;if (!admin.istableavailable(tablename.valueof(tablename))) {htabledescriptor hbasetable = new htabledescriptor(tablename.valueof(tablename));hbasetable.addfamily(new hcolumndescriptor(name));hbasetable.addfamily(new hcolumndescriptor(contact_info));hbasetable.addfamily(new hcolumndescriptor(personal_info));admin.createtable(hbasetable);}} catch (exception e) {e.printstacktrace();} finally {try {if (admin != null) {admin.close();}if (connection != null && !connection.isclosed()) {connection.close();}} catch (exception e2) {e2.printstacktrace();}}}}hadoop+hbase搭建云存储总结 pdf
hbase 结点之间时间不一致造成regionserver启动失败
hadoop+zookeeper+hbase集群配置
hadoop集群安装&hbase实验环境搭建
基于hadoop集群的hbase集群的配置 ‘
hadoop安装部署笔记之-hbase完全分布模式安装
单机版搭建hbase环境图文教程详解
hbase 的详细介绍:请点这里
hbase 的下载地址:请点这里
本文永久更新链接地址:
其它类似信息

推荐信息