1. 程式人生 > >HBase實操 | 如何使用HBase儲存文字檔案

HBase實操 | 如何使用HBase儲存文字檔案

1.文件編寫目的


Fayson在前面的文章中介紹了《如何在CDH中使用Solr對HDFS中的JSON資料建立全文索引》和《如何使用Flume準實時建立Solr的全文索引》,假如我們有大量的文字檔案,我們應該如何儲存到Hadoop中,並實現文字檔案的全文檢索呢。為了介紹如何對文字檔案進行全文檢索,本文會先介紹如何使用HBase儲存文字檔案。雖然HDFS中也可以直接儲存這種非結構化資料,但是我們知道像這種文字檔案,一般都是10KB~1MB的小檔案,因為HDFS並不擅長儲存大量小檔案,所以這裡選擇HBase來儲存。


內容概述
1.檔案處理流程
2.準備上傳檔案的Java程式碼
3.執行程式碼
4.Hue中查詢驗證


測試環境
1.RedHat7.4
2.CM5.14.3
3.CDH5.14.2
4.叢集未啟用Kerberos


2.檔案處理流程 1c8408383a69d8d993159338c0f95cd662e27ea2


1.如上圖所示,Fayson先在本地準備了一堆記事本檔案,有中文內容的,英文內容的,有中文名的,也有英文名的。
f9530ddc6a953ec5b2bf7e8989c22d5a602bf083

中文內容示例
3e45c12e913f4401b050df807682261234d73a44
04a590dc077ca79e0fcecf37de7f4ec51439591e
2.然後通過Java程式遍歷本地的資料夾所有文字檔案入庫到HBase,在入庫過程中,我們讀取文字檔案的檔名作為Rowkey,另外將整個文字內容轉為bytes儲存在HBase表的一個column裡。
3.最後可以通過Hue來進行檢視文字檔案的內容,當然你也可以考慮對接到你自己的查詢系統。


3.準備上傳檔案的Java程式碼


1.首先是準備Maven檔案 cd5f304c0029e86d56ce26bbe869a95faaffaea3

6fac34262525b483de0c7e3de37ae038f3036fa7
8f5f6ffb00e5bc35c24cbe0b666cbdb98f5bbb66

2.準備上傳檔案到HBase的Java程式碼 2.準備上傳檔案到HBase的Java程式碼
380d33cf4b2ace7ee5d759c62e0e854ce2719c63
09b86b3bc5d9fed80f4b06660f9a0ee7d313cb17
dba17e82ba9364edf1336bcee8ecbf5bc1eee678

2.準備上傳檔案到HBase的Java程式碼
b95ec03053b8165a641f75f27250ad45b9e0a753
3f7d4fb23bc21943b041d558cf21934c6734c6ae
ae240e656afc90a695f55965f7fc899ffc61a488
56271bf7854fd07a0a2a87e41f402660952f92f9
4.執行程式碼



1.首先我們在HBase中建一張表用來儲存文字檔案
578df5fde4df90a0cc855234b602169cfeb38829

2.配置客戶端Windows機器的hosts檔案
bdc123038f73e44ee48296ae5d4af7c95d0b95dd

3.注意修改程式碼中的配置項,如文字檔案所在的目錄,叢集的Zookeeper地址等。Fayson這裡為了使用方便,就不打成jar包到叢集執行,直接在Eclipse裡執行程式碼。
b748a6c10abdc722bab062f58e3750b1f496ca83
4.到HBase中進行查詢確認
ec43454d107500a78c0127c278650b314ad9b43c


一共21條,表明全部入庫成功
a1151e340a5fbdbbdcabbe6c52c21e5011f50a25

5.Hue中查詢驗證



1.從Hue中進入HBase的模組 472f505b05f4b6a1de0947b7e14a579749cfce66

單擊某個column,可以檢視整個文字內容 0808f16b91bd495752ec62087ab49c9d5bf2d0e2


2.查詢某一個Rowkey進行測試
57f7d39d56669f970176df0e16da86a99fc611a6

本文所使用的程式碼原始碼GitHub地址:

https://github.com/fayson/cdhproject/blob/master/hbasedemo/src/main/java/com/cloudera/hbase/Text2HBase.java

https://github.com/fayson/cdhproject/tree/master/hbasedemo/full-text-index


d3f2f0da5b6761a64c7049db7719525a2c492a0c


大家工作學習遇到HBase技術問題,把問題釋出到HBase技術社群論壇http://hbase.group,歡迎大家論壇上面提問留言討論。想了解更多HBase技術關注HBase技術社群公眾號(微訊號:hbasegroup),非常歡迎大家積極投稿。



096973d69f34b1380151180fd0a8ff2cade5bced


HBase技術交流社群 - 阿里官方“HBase生態+Spark社群大群”點選加入:https://dwz.cn/Fvqv066s