目錄

一、需求與數(shù)據(jù)集

二、準備工作

1、創(chuàng)建一個maven工程?

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

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

?4、查看目錄

5、創(chuàng)建基本的包結(jié)構(gòu)與類

6、創(chuàng)建類?

7、結(jié)果?

三、案例一、使用javaapi創(chuàng)建hbase的表

1、編寫代碼

2、運行

1)開啟集群

2)運行結(jié)果

3、查看創(chuàng)建的表

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

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

2、調(diào)用方法

?3、getAdmin方法

4、運行

5、查看結(jié)果

五、案例三、往創(chuàng)建的表中插入數(shù)據(jù)

1、編寫添加數(shù)據(jù)的方法

2、調(diào)用方法

?3、getAdmin方法

4、運行

?5、查看結(jié)果

?六、案例四、查看一條數(shù)據(jù)

1、編寫方法

2、調(diào)用方法

3、查看結(jié)果

七、案例五、刪除一條數(shù)據(jù)、

1、編寫方法

2、調(diào)用

??3、運行

?4、查看結(jié)果

八、案例六、導(dǎo)入數(shù)據(jù)?

1、需求

2、Import JOB導(dǎo)入大量的數(shù)據(jù)

3、上傳數(shù)據(jù)至hdfs

4、導(dǎo)入數(shù)據(jù)

1）啟動yarn

2）創(chuàng)建表

?3）運行導(dǎo)入命令

4）運行結(jié)果?

5、查看數(shù)據(jù)

6、count計數(shù)

7、?Mapreduce計數(shù)?

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

1、需求分析

2、編寫代碼

3、調(diào)用方法

?4、查看結(jié)果

5、輸出代碼的改進

?6、解決數(shù)值型數(shù)據(jù)顯示亂碼的問題

十、Export Job 導(dǎo)出數(shù)據(jù)

1、導(dǎo)出數(shù)據(jù)

2、查看結(jié)果

---

一、需求與數(shù)據(jù)集

某自來水公司，需要存儲大量的繳費明細數(shù)據(jù)，以下截取了繳費明細的一部分內(nèi)容：

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

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

且可以使用java來訪問這些數(shù)據(jù)。

二、準備工作

idea的maven環(huán)境搭建成功

1、創(chuàng)建一個maven工程?

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

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

?復(fù)制到項目中

?4、查看目錄

5、創(chuàng)建基本的包結(jié)構(gòu)與類

6、創(chuàng)建類?

7、結(jié)果?

三、案例一、使用javaapi創(chuàng)建hbase的表

使用java-api創(chuàng)建hbase的表

創(chuàng)建一個名為water_bill的表，包含一個列簇

1、編寫代碼

2、運行

1)開啟集群

2)運行結(jié)果

3、查看創(chuàng)建的表

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

刪除剛剛創(chuàng)建的表

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

2、調(diào)用方法

?3、getAdmin方法

4、運行

5、查看結(jié)果

五、案例三、往創(chuàng)建的表中插入數(shù)據(jù)

1、編寫添加數(shù)據(jù)的方法

?

2、調(diào)用方法

?3、getAdmin方法

4、運行

?5、查看結(jié)果

?六、案例四、查看一條數(shù)據(jù)

查看顯示rowkey是49441091的數(shù)據(jù)

1、編寫方法

獲取某列的值

獲取某行的值

2、調(diào)用方法

getTable調(diào)用

getone調(diào)用

3、查看結(jié)果

gettable

getone

七、案例五、刪除一條數(shù)據(jù)、

1、編寫方法

2、調(diào)用

?3、運行

?4、查看結(jié)果

八、案例六、導(dǎo)入數(shù)據(jù)?

1、需求

有一份10W條記錄的抄表數(shù)據(jù)文件，需求將其導(dǎo)入hbase中

2、Import JOB導(dǎo)入大量的數(shù)據(jù)

在hbase中，有一個import的MR作業(yè)，可以專門用來將數(shù)據(jù)導(dǎo)入到hbase中

用法

Hbase org.apache.hadoop.hbase.mapreduce.Import表名hdfs數(shù)據(jù)文件路徑

3、上傳數(shù)據(jù)至hdfs

4、導(dǎo)入數(shù)據(jù)

1）啟動yarn

2）創(chuàng)建表

?3）運行導(dǎo)入命令

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

4）運行結(jié)果?

5、查看數(shù)據(jù)

6、count計數(shù)

7、?Mapreduce計數(shù)?

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

1、需求分析

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

年6月30日的所有抄表數(shù)據(jù)

2、編寫代碼

3、調(diào)用方法

?4、查看結(jié)果

5、輸出代碼的改進

?6、解決數(shù)值型數(shù)據(jù)顯示亂碼的問題

打印顯示字符串?dāng)?shù)據(jù)正常

顯示結(jié)果

十、Export Job 導(dǎo)出數(shù)據(jù)

用法：

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

1、導(dǎo)出數(shù)據(jù)

2、查看結(jié)果

總結(jié)

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

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。