開場白：

Hive與HBase的整合功能的實現是利用兩者本身對外的API接口互相進行通信，相互通信主要是依靠hive_hbase-handler.jar工具類 ( Hive Storage Handlers )， 大致意思如圖所示：

口水：

?對 hive_hbase-handler.jar 這個東東還有點興趣，有空來磋磨一下。

一、2個注意事項：

1、需要的軟件有 Hadoop、Hive、Hbase、Zookeeper，Hive與HBase的整合對Hive的版本有要求，所以不要下載.0.6.0以前的老版本，Hive.0.6.0的版本才支持與HBase對接，因此在Hive的lib目錄下可以看見多了hive_hbase-handler.jar這個jar包，他是Hive擴展存儲的Handler ，HBase 建議使用 0.20.6的版本，這次我沒有啟動HDFS的集群環境，本次所有測試環境都在一臺機器上。

?????

2、運行Hive時，也許會出現如下錯誤，表示你的JVM分配的空間不夠， 錯誤信息 如下：

Invalid maximum heap size: -Xmx4096m

The specified size exceeds the maximum representable size.

Could not create the Java virtual machine.

解決方法：

/work/hive/bin/ext# vim util/execHiveCmd.sh 文件中第33行

修改，

HADOOP_HEAPSIZE=4096

為

HADOOP_HEAPSIZE=256

另外，在 /etc/profile/ 加入 export $HIVE_HOME=/work/hive

二、啟動運行環境

1啟動Hive

hive –auxpath /work/hive/lib/hive_hbase-handler.jar,/work/hive/lib/hbase-0.20.3.jar,/work/hive/lib/zookeeper-3.2.2.jar -hiveconf hbase.master=127.0.0.1:60000

加載 Hive需要的工具類，并且指向HBase的master服務器地址，我的HBase master服務器和Hive運行在同一臺機器，所以我指向本地。

2啟動HBase

/work/hbase/bin/hbase master start

3啟動Zookeeper

/work/zookeeper/bin/zkServer.sh start

三、執行

在Hive中創建一張表，相互關聯的表

CREATE TABLE hbase_table_1(key int, value string) STORED BY 'org.apache.hadoop.hive.hbase.HBaseStorageHandler' WITH SERDEPROPERTIES ("hbase.columns.mapping" = ":key,cf1:val") TBLPROPERTIES (" hbase.table.name " = "xyz");

在運行一個在Hive中建表語句，并且將數據導入

建表

????CREATE TABLE pokes (foo INT, bar STRING);

數據導入

????LOAD DATA LOCAL INPATH '/work/hive/examples/files/kv1.txt' OVERWRITE INTO TABLE pokes;

在Hive與HBase關聯的表中 插入一條數據

????INSERT OVERWRITE TABLE hbase_table_1 SELECT * FROM pokes WHERE foo=98;

運行成功后，如圖所示：

插入數據時采用了MapReduce的策略算法，并且同時向HBase寫入，如圖所示：

在HBase shell中運行 scan 'xyz' 和describe "xyz" 命令，查看表結構，運行結果如圖所示：

xyz是通過Hive在Hbase中創建的表，剛剛在Hive的建表語句中指定了映射的屬性? "hbase.columns.mapping" = ":key,cf1:val"? 和 在HBase中建表的名稱? " hbase.table.name " = "xyz"

在hbase在運行put命令，插入一條記錄

???? put 'xyz','10001','cf1:val',' www.javabloger.com '

在hive上運行查詢語句，看看剛剛在hbase中插入的數據有沒有同步過來，

????select * from hbase_table_1 WHERE key=10001;

如圖所示：

最終的效果

????以上整合過程和操作步驟已經執行完畢，現在 Hive中添加記錄HBase中有記錄添加，同樣你在HBase中添加記錄Hive中也會添加 ， 表示Hive與HBase整合成功，對海量級別的數據我們是不是可以在HBase寫入，在Hive中查詢 喃？因為 HBase 不支持 復雜的查詢，但是HBase可以作為基于 key 獲取一行或多行數據，或者掃描數據區間，以及過濾操作。而 復雜的 查詢可以讓 Hive 來完成 ，一個作為存儲的入口(HBase)，一個作為查詢的入口(Hive)。如下圖示。

????

????

????呵呵，見笑了，以上只是我面片的觀點。

先這樣，稍后我將繼續更新，感謝你的閱讀。

??