目錄

一、需求與數據集

二、準備工作

1、創建一個maven工程?

2、修改prom文件，添加依賴

3、復制Hadoop的配置文件core-site.xml和HBase的配置文件hbase-site.xml到resources目錄

?4、查看目錄

5、創建基本的包結構與類

6、創建類?

7、結果?

三、案例一、使用javaapi創建hbase的表

1、編寫代碼

2、運行

1)開啟集群

2)運行結果

3、查看創建的表

四、案例二、使用javaapi刪除表

1、編寫刪除表的方法代碼

2、調用方法

?3、getAdmin方法

4、運行

5、查看結果

五、案例三、往創建的表中插入數據

1、編寫添加數據的方法

2、調用方法

?3、getAdmin方法

4、運行

?5、查看結果

?六、案例四、查看一條數據

1、編寫方法

2、調用方法

3、查看結果

七、案例五、刪除一條數據、

1、編寫方法

2、調用

??3、運行

?4、查看結果

八、案例六、導入數據?

1、需求

2、Import JOB導入大量的數據

3、上傳數據至hdfs

4、導入數據

1）啟動yarn

2）創建表

?3）運行導入命令

4）運行結果?

5、查看數據

6、count計數

7、?Mapreduce計數?

?九、案例六、查詢2020年6月份所有用戶的用水量

1、需求分析

2、編寫代碼

3、調用方法

?4、查看結果

5、輸出代碼的改進

?6、解決數值型數據顯示亂碼的問題

十、Export Job 導出數據

1、導出數據

2、查看結果

---

一、需求與數據集

某自來水公司，需要存儲大量的繳費明細數據，以下截取了繳費明細的一部分內容：

用戶id姓地址性繳費時間表示表示用量合查表日期最遲繳費

因為繳費明細的數據記錄非常龐大，該公司的信息部門決定使用hbase來存儲這些數據，并

且可以使用java來訪問這些數據。

二、準備工作

idea的maven環境搭建成功

1、創建一個maven工程?

2、修改prom文件，添加依賴

3、復制Hadoop的配置文件core-site.xml和HBase的配置文件hbase-site.xml到resources目錄

?復制到項目中

?4、查看目錄

5、創建基本的包結構與類

6、創建類?

7、結果?

三、案例一、使用javaapi創建hbase的表

使用java-api創建hbase的表

創建一個名為water_bill的表，包含一個列簇

1、編寫代碼

2、運行

1)開啟集群

2)運行結果

3、查看創建的表

四、案例二、使用javaapi刪除表

刪除剛剛創建的表

1、編寫刪除表的方法代碼

2、調用方法

?3、getAdmin方法

4、運行

5、查看結果

五、案例三、往創建的表中插入數據

1、編寫添加數據的方法

?

2、調用方法

?3、getAdmin方法

4、運行

?5、查看結果

?六、案例四、查看一條數據

查看顯示rowkey是49441091的數據

1、編寫方法

獲取某列的值

獲取某行的值

2、調用方法

getTable調用

getone調用

3、查看結果

gettable

getone

七、案例五、刪除一條數據、

1、編寫方法

2、調用

?3、運行

?4、查看結果

八、案例六、導入數據?

1、需求

有一份10W條記錄的抄表數據文件，需求將其導入hbase中

2、Import JOB導入大量的數據

在hbase中，有一個import的MR作業，可以專門用來將數據導入到hbase中

用法

Hbase org.apache.hadoop.hbase.mapreduce.Import表名hdfs數據文件路徑

3、上傳數據至hdfs

4、導入數據

1）啟動yarn

2）創建表

?3）運行導入命令

hbase org.apache.hadoop.hbase.mapreduce.Import WATER_BILL /water_bill/

4）運行結果?

5、查看數據

6、count計數

7、?Mapreduce計數?

?九、案例六、查詢2020年6月份所有用戶的用水量

1、需求分析

在hbase中用scan+filter實現過濾查詢。2020年6月份其實就是從2020年6月1號到2020

年6月30日的所有抄表數據

2、編寫代碼

3、調用方法

?4、查看結果

5、輸出代碼的改進

?6、解決數值型數據顯示亂碼的問題

打印顯示字符串數據正常

顯示結果

十、Export Job 導出數據

用法：

hbase org.apache.hadoop.hbase.mapreduce.Export 表名 路徑

1、導出數據

2、查看結果

總結

以上是生活随笔為你收集整理的Hbase之一月速成：Hbase的JavaAPI操作的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。