使用Java API操作HBase
- 一 創(chuàng)建Maven項目
- 二 添加依賴
- 三 使用Java API開發(fā)代碼
- 編寫統(tǒng)一工具類
- 編寫建表代碼
- 編寫插入數(shù)據(jù)
- 四 打包、上傳Jar包
- 五 測試
-
一 創(chuàng)建Maven項目
- 這部分操作在我的以往博客多有提及,有需求請點擊下方鏈接
鏈接: Maven安裝及Maven工程的創(chuàng)建.
二 添加依賴

三 使用Java API開發(fā)代碼
編寫統(tǒng)一工具類
package cn.kgc.kb09.test.util;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.client.Admin;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.ConnectionFactory;
import java.io.IOException;
public class HBaseConfs {private HBaseConfs(){};private static Configuration getconf(){Configuration conf = HBaseConfiguration.create();conf.addResource(new Path("/opt/hbase/conf/hbase-site.xml"));conf.addResource(new Path("/opt/hadoop2.6.0/etc/hadoop/core-site.xml"));return conf;}public static Connection getConn() {Connection conn=null;try {conn= ConnectionFactory.createConnection(getconf());} catch (IOException e) {e.printStackTrace();}return conn;}