本文是對(duì)Hive組件的學(xué)習(xí)的一個(gè)初步總結(jié)隙券,包括如下章節(jié)的內(nèi)容:
- Hive是什么
- Hive安裝
- 快速上手
- Hive元數(shù)據(jù)
- 數(shù)據(jù)存儲(chǔ)
- 運(yùn)行模式
參考資料:
1、本文介紹的內(nèi)容依賴hadoop環(huán)境作瞄,關(guān)于hadoop運(yùn)行環(huán)境的搭建可參見(jiàn)《Hadoop運(yùn)行環(huán)境搭建》想罕。
2滔金、學(xué)習(xí)Hive前,最好對(duì)關(guān)系數(shù)據(jù)庫(kù)以及sql語(yǔ)句有所熟悉痘昌。
一钥勋、Hive是什么
Hive是基于Hadoop的一個(gè)數(shù)據(jù)倉(cāng)庫(kù),它將結(jié)構(gòu)化的數(shù)據(jù)文件(一般保存在hdfs上)映射為一張表辆苔,并提供類sql(稱為hsql)查詢功能算灸,Hive框架將hsql語(yǔ)句轉(zhuǎn)化為一系列mapreduce任務(wù)來(lái)對(duì)hdfs上的文件進(jìn)行分析。相對(duì)于用java代碼編寫(xiě)mapreduce程序來(lái)說(shuō)驻啤,編寫(xiě)sql語(yǔ)句要簡(jiǎn)單和快速很多菲驴。Hive的優(yōu)勢(shì)明顯:快速開(kāi)發(fā),技術(shù)門(mén)檻低骑冗,可擴(kuò)展性(自由擴(kuò)展集群規(guī)模)赊瞬,延展性(支持自定義函數(shù))。
Hive是由Facebook開(kāi)發(fā)贼涩,后來(lái)由Apache軟件基金會(huì)開(kāi)發(fā)巧涧,并作為進(jìn)一步將它作為名義下Apache Hive為一個(gè)開(kāi)源項(xiàng)目。
Hive是一種數(shù)據(jù)倉(cāng)庫(kù)系統(tǒng)遥倦,提到數(shù)據(jù)倉(cāng)庫(kù)谤绳,我們通常會(huì)想到數(shù)據(jù)庫(kù)。為了更好地理解Hive作為數(shù)據(jù)倉(cāng)庫(kù)的應(yīng)用場(chǎng)景袒哥。這里簡(jiǎn)單介紹下數(shù)據(jù)倉(cāng)庫(kù)和數(shù)據(jù)庫(kù)的區(qū)別缩筛,可以從兩個(gè)角度看來(lái)它們的區(qū)別:
1、數(shù)據(jù)庫(kù)和數(shù)據(jù)倉(cāng)庫(kù)都是通過(guò)某個(gè)軟件系統(tǒng)堡称,基于某種數(shù)據(jù)模型來(lái)組織瞎抛、管理數(shù)據(jù)。但是却紧,數(shù)據(jù)庫(kù)通常更關(guān)注業(yè)務(wù)交易處理(OLTP)桐臊,而數(shù)據(jù)倉(cāng)庫(kù)更關(guān)注數(shù)據(jù)分析層面(OLAP)钞艇,由此產(chǎn)生的數(shù)據(jù)庫(kù)模型上也會(huì)有很大的差異。
2豪硅、數(shù)據(jù)庫(kù)通常追求交易的速度,交易完整性挺物,數(shù)據(jù)的一致性等懒浮,在數(shù)據(jù)庫(kù)模型上主要遵從范式模型(1NF,2NF识藤,3NF等)砚著,從而盡可能減少數(shù)據(jù)冗余,保證引用完整性痴昧;而數(shù)據(jù)倉(cāng)庫(kù)強(qiáng)調(diào)數(shù)據(jù)分析的效率稽穆,復(fù)雜查詢的速度,數(shù)據(jù)之間的相關(guān)性分析赶撰,所以在數(shù)據(jù)庫(kù)模型上舌镶,數(shù)據(jù)倉(cāng)庫(kù)喜歡使用多維模型,從而提高數(shù)據(jù)分析的效率豪娜。
二餐胀、Hive安裝
(一)前置準(zhǔn)備
Hive一般運(yùn)行在工作站上,它把sql查詢轉(zhuǎn)換為一系列的mapreduce任務(wù)瘤载,提交到hadoop集群上運(yùn)行否灾。安裝Hive之前,首先必須在準(zhǔn)備安裝Hive的工作站上安裝與集群相同版本的hadoop鸣奔,或者直接在集群環(huán)境的某臺(tái)機(jī)器上安裝Hive墨技。
因?yàn)镠ive工作站上也要安裝Hadoop,所以我們?cè)陂_(kāi)發(fā)階段挎狸,可以在Hive工作站上以獨(dú)立(本地)模式或偽分布式模式啟動(dòng)hadoop扣汪。這時(shí)讓Hive程序與本機(jī)上的hadoop交互來(lái)進(jìn)行開(kāi)發(fā)調(diào)試,確保功能無(wú)誤后伟叛,再讓Hive程序連接到實(shí)際的集群環(huán)境上進(jìn)行功能私痹,尤其性能的驗(yàn)證。
關(guān)于hadoop在本地如何安裝和運(yùn)行统刮,可參考《Hadoop運(yùn)行環(huán)境搭建》紊遵。
(二)下載版本
下載相應(yīng)的Hive版本,解壓到某個(gè)目錄下侥蒙。注意暗膜,下載的Hive版本需要與對(duì)應(yīng)的hadoop版本匹配”揆茫可以通過(guò)http://hive.apache.org/downloads.html 查看Hive版本與Hadoop版本的依賴關(guān)系学搜。在本文的案例中娃善,我們使用的是Hive版本是hive-1.2.2。
(三)配置環(huán)境變量
export Hive_HOME=/home/hadoop/hive
PATH=$PATH:$Hive_HOME/bin
說(shuō)明:上面是假設(shè)Hive解壓到/home/hadoop目錄下瑞佩,具體要根據(jù)實(shí)際目錄來(lái)設(shè)置聚磺。
三、快速上手
安裝好Hive后炬丸,我們可以利用Hive提供的交互式命令行程序來(lái)快速的學(xué)習(xí)如何使用Hsql來(lái)進(jìn)行數(shù)據(jù)分析瘫寝。
Hive提供了一個(gè)名稱叫hive的可執(zhí)行程序(實(shí)際是一個(gè)shell腳本),位于Hive解壓后的bin目錄中稠炬,因?yàn)榍懊娴沫h(huán)境變量設(shè)置中bin目錄已經(jīng)加到PATH環(huán)境變量中焕阿,所以可以在任意當(dāng)前目錄下運(yùn)行hive程序,運(yùn)行hive后首启,會(huì)出現(xiàn)一個(gè)交互式運(yùn)行界面暮屡,這樣可以執(zhí)行Hive 的sql語(yǔ)句了,輸入exit毅桃;退出交互式界面褒纲。如下面例子:
[hadoop@localhost ~]$
[hadoop@localhost ~]$ hive
............
hive>
hive> show tables;
OK
Time taken: 1.047 seconds
hive> exit;
[hadoop@localhost ~]$
可以看出,運(yùn)行hive程序钥飞,出現(xiàn)一個(gè)交互式界面外厂,這時(shí)輸入了show tables命令(該命令顯示所有的Hive表,因?yàn)檫€沒(méi)任何建表操作代承,所有沒(méi)有數(shù)據(jù))汁蝶,執(zhí)行exit命令退出交互式運(yùn)行界面。注意论悴,在hive程序的交互式執(zhí)行中掖棉,命令要以分號(hào)結(jié)尾。
下面我們?cè)偻ㄟ^(guò)一個(gè)簡(jiǎn)單的例子來(lái)看下如何創(chuàng)建Hive表膀估、導(dǎo)入數(shù)據(jù)和進(jìn)行數(shù)據(jù)查詢幔亥。
(一)創(chuàng)建表
在hive>提示符下,我們創(chuàng)建如下的表察纯,hsql語(yǔ)句如下:
create table student(id int, name string, sex string, age int, department string)
row format delimited
fields terminated by ",";
這時(shí)我們?cè)賵?zhí)行 show tables 命令會(huì)發(fā)現(xiàn)顯示 student表名帕棉。
(二)查看數(shù)據(jù)
我們執(zhí)行hsql查詢語(yǔ)句:
select * from student;
會(huì)成功,但沒(méi)有數(shù)據(jù)饼记∠惆椋可以看出,這個(gè)查詢語(yǔ)句與標(biāo)準(zhǔn)sql沒(méi)有區(qū)別具则。
(三)導(dǎo)入數(shù)據(jù)
準(zhǔn)備一個(gè)文本文件student.txt即纲,其文件中的數(shù)據(jù)格式要符合上面創(chuàng)建表的結(jié)構(gòu),文件可以在本地博肋,也可以在htfs上低斋。文件的內(nèi)容如:
95002,劉晨,女,19,IS
95017,王風(fēng)娟,女,18,IS
95018,王一,女,19,IS
95013,馮偉,男,21,CS
95014,王小麗,女,19,CS
95019,邢小麗,女,19,IS
95020,趙錢(qián),男,21,IS
執(zhí)行命令
load data local inpath "/home/hadoop/localdata/student.txt" into table student;
上面命令會(huì)把本地的文件 /home/hadoop/localdata/student.txt 導(dǎo)入到hdfs的Hive倉(cāng)庫(kù)目錄中蜂厅,作為Hive表的數(shù)據(jù)。關(guān)于Hive的倉(cāng)庫(kù)目錄膊畴,下面章節(jié)會(huì)詳細(xì)介紹掘猿。
這時(shí)我們?cè)賵?zhí)行select 語(yǔ)句,會(huì)發(fā)現(xiàn)查詢的數(shù)據(jù)就是文件中的數(shù)據(jù)唇跨。
我們也可以把hdfs上的文件導(dǎo)入到Hive中术奖,這時(shí)只需要把上面命令中 inpath 前面的local去掉,然后inpath 后面是hdfs上的文件路徑即可轻绞。不過(guò),如果是load hdfs上的文件佣耐,這個(gè)文件會(huì)被刪除掉政勃,相當(dāng)于是被移到Hive倉(cāng)庫(kù)中了。
注意:Hive不支持標(biāo)準(zhǔn)sql的insert單條記錄的操作兼砖。
(四)刪除表
刪除表的hsql語(yǔ)句是:
drop table 表名
這和關(guān)系數(shù)據(jù)庫(kù)刪除表的sql語(yǔ)句一樣奸远。
(五)非交互式執(zhí)行命令
前面我們介紹的都是在Hive交互式命令行界面下執(zhí)行命令的,但在很多時(shí)候讽挟,我們往往需要非交互式的執(zhí)行懒叛,比如在希望在一個(gè)腳本中執(zhí)行Hive的hsql命令。
這有兩種方式耽梅,一種是將hsql命令寫(xiě)入到腳本文件中薛窥,假設(shè)寫(xiě)入的文件名為script.q。然后我們?cè)诳刂婆_(tái)下執(zhí)行:
hive -f script.q
這樣hive程序會(huì)被啟動(dòng)眼姐,依次執(zhí)行腳本中的每條hsql命令诅迷。所有命令執(zhí)行完畢后,hive程序會(huì)自動(dòng)退出众旗。
對(duì)于內(nèi)容(hsql命令)較少的腳本罢杉,可以直接將內(nèi)容嵌入到命令中,而不用寫(xiě)到一個(gè)文件中贡歧。如在控制臺(tái)下執(zhí)行如下命令:
hive -e “select * from student”
這樣hive程序會(huì)被啟動(dòng)滩租,并執(zhí)行跟著的hsql語(yǔ)句,執(zhí)行完畢后利朵,hive程序會(huì)自動(dòng)退出律想。
上面我們通過(guò)例子快速的了解了如何使用Hive。但還有很多問(wèn)題需要弄清楚绍弟。比如創(chuàng)建的Hive表的這個(gè)表定義信息存儲(chǔ)在哪里了蜘欲?表背后對(duì)應(yīng)的數(shù)據(jù)(load操作上傳的)文件放到哪里了?除了create和select語(yǔ)句晌柬,Hive還提供了哪些類sql語(yǔ)句姥份,與標(biāo)準(zhǔn)sql有哪些區(qū)別郭脂?作為最終用戶,除了通過(guò)交互式界面來(lái)執(zhí)行hsql進(jìn)行操作外澈歉,還有哪些方式展鸡,比如如何編寫(xiě)java等程序使用Hive?
下面我們接著來(lái)介紹Hive中的一些重要概念。對(duì)于Hsql更多的語(yǔ)法和信息埃难,本文不再介紹莹弊。
四、Hive元數(shù)據(jù)
我們使用Hive涡尘,首先要?jiǎng)?chuàng)建表忍弛,這里的表只是對(duì)hdfs上數(shù)據(jù)文件的的一種結(jié)構(gòu)描述(即表的定義信息),那這個(gè)表的定義信息保存在哪里呢考抄?
Hive將表的定義信息细疚,以及其它一些信息(如服務(wù)信息),稱為Hive的元數(shù)據(jù)川梅,元數(shù)據(jù)不是保存在hdfs上的疯兼,而是保存在關(guān)系數(shù)據(jù)庫(kù)中的,稱為metastore贫途。
Hive的metastore(元數(shù)據(jù)存儲(chǔ))有三種配置方式:
1吧彪、內(nèi)嵌Derby配置
內(nèi)嵌方式是Hive默認(rèn)的metastore配置,這時(shí)不需要修改任何Hive的配置文件丢早。元數(shù)據(jù)是保存在一個(gè)以本地磁盤(pán)作為存儲(chǔ)的Derby數(shù)據(jù)庫(kù)實(shí)例中姨裸。Hive自帶了對(duì)Derby數(shù)據(jù)庫(kù)的支持。如下圖所示:
一個(gè)Derby數(shù)據(jù)庫(kù)的數(shù)據(jù)庫(kù)相關(guān)文件在物理上對(duì)應(yīng)一個(gè)本地磁盤(pán)的目錄怨酝,每次只能有一個(gè)內(nèi)嵌的Derby數(shù)據(jù)庫(kù)實(shí)例來(lái)訪問(wèn)這些數(shù)據(jù)庫(kù)文件啦扬。因?yàn)镠ive運(yùn)行需要獲取元數(shù)據(jù)。這樣的話凫碌,同時(shí)只能有一個(gè)Hive會(huì)話扑毡。
在內(nèi)嵌模式下,當(dāng)我們?cè)诳刂婆_(tái)下首次運(yùn)行hive程序(如上一節(jié)介紹)盛险,會(huì)發(fā)現(xiàn)在運(yùn)行hive程序的當(dāng)前目錄下生成了一個(gè)metastore_db目錄瞄摊,該目錄就是Derby數(shù)據(jù)庫(kù)文件存放地。當(dāng)我們進(jìn)行了創(chuàng)建表等操作苦掘,這些表定義的元數(shù)據(jù)就存放到Derby數(shù)據(jù)庫(kù)中换帜。因?yàn)橐粋€(gè)Derby數(shù)據(jù)庫(kù)只支持一個(gè)實(shí)例訪問(wèn),所以當(dāng)我們?nèi)绻谕瑯拥漠?dāng)前目錄下再次運(yùn)行hive程序就會(huì)報(bào)錯(cuò)鹤啡。當(dāng)然我們可以在另外的目錄下運(yùn)行hive程序惯驼,只不過(guò)這樣會(huì)在另外的目錄下生成另外一個(gè)Derby數(shù)據(jù)庫(kù),這兩個(gè)Derby數(shù)據(jù)庫(kù)是無(wú)關(guān)的。
因此祟牲,在內(nèi)嵌模式下隙畜,一旦hive程序退出后,如果我們?cè)俅螁?dòng)说贝,并希望能獲取到原來(lái)操作產(chǎn)生的元數(shù)據(jù)议惰,一定要在原來(lái)的目錄下啟動(dòng)hive程序,這樣關(guān)聯(lián)的才是相同的Derby數(shù)據(jù)庫(kù)乡恕。
2言询、本地配置
如果我們希望能同時(shí)支持多個(gè)會(huì)話,則需要一個(gè)獨(dú)立的數(shù)據(jù)庫(kù)來(lái)保存Hive元數(shù)據(jù)傲宜,這稱為本地配置运杭。對(duì)于獨(dú)立的metastore,一般采用mysql數(shù)據(jù)庫(kù)函卒。對(duì)于本地配置辆憔,Hive引擎和metastore服務(wù)仍然運(yùn)行在同一個(gè)jvm進(jìn)程中。如下圖所示:
3谆趾、遠(yuǎn)程配置
這種模式下,metastore服務(wù)會(huì)作為一個(gè)獨(dú)立的服務(wù)進(jìn)程運(yùn)行叛本,我們可以配置啟動(dòng)多個(gè)metastore服務(wù)進(jìn)程沪蓬。如下圖所示:
使用本地配置或遠(yuǎn)程配置,需要一些額外的工作要處理来候,如安裝mysql數(shù)據(jù)庫(kù)跷叉,修改Hive的相關(guān)配置文件。但是無(wú)論采用內(nèi)嵌方式营搅,或哪種方式云挟,站在應(yīng)用或?qū)W習(xí)的角度是沒(méi)有太多區(qū)別的。在本文中转质,我們不對(duì)本地和遠(yuǎn)程模式的如何配置做介紹园欣。為了簡(jiǎn)單化,我們?cè)趦?nèi)嵌模式下進(jìn)行例子的演示和說(shuō)明休蟹。
五沸枯、數(shù)據(jù)存儲(chǔ)
通過(guò)上一節(jié)的介紹,我們已經(jīng)知道赂弓,Hive表的定義信息作為元數(shù)據(jù)存在關(guān)系數(shù)據(jù)庫(kù)中绑榴,那表背后的實(shí)際數(shù)據(jù)是存儲(chǔ)在哪里呢?
(一)表分類
其實(shí)Hive的表分兩種類型盈魁,一是托管表翔怎,二是外部表。托管表的數(shù)據(jù)文件是存放到Hive的數(shù)據(jù)倉(cāng)庫(kù)目錄下,而外部表的數(shù)據(jù)文件由建表時(shí)指定赤套,可以是任意的hdfs目錄飘痛。也就是說(shuō)對(duì)于托管表其數(shù)據(jù)文件存儲(chǔ)由Hive來(lái)管理。而對(duì)于外部表于毙,其數(shù)據(jù)文件存儲(chǔ)由開(kāi)發(fā)者自己來(lái)管理敦冬。
我們上面舉的建表例子是托管表。對(duì)于外部表唯沮,我們先知道這個(gè)概念脖旱,具體的創(chuàng)建和使用本文不作介紹。
(二)倉(cāng)庫(kù)目錄
對(duì)于Hive的托管表介蛉,對(duì)應(yīng)的數(shù)據(jù)文件是存放在Hive的倉(cāng)庫(kù)目錄中萌庆,默認(rèn)是hdfs系統(tǒng)的/user/hive/warehouse目錄下(可以在hive-site.xml配置文件中配置自己需要的位置,配置屬性為hive.metastore.warehouse.dir)币旧。
Hive所創(chuàng)建的每張Hive表都會(huì)在該倉(cāng)庫(kù)目錄下生成一個(gè)目錄践险,目錄名同表名。在我們使用load命令給表導(dǎo)入數(shù)據(jù)時(shí)吹菱,實(shí)際load命令指定的數(shù)據(jù)文件(來(lái)源是本地磁盤(pán)或hdfs上的文件)會(huì)被存放到倉(cāng)庫(kù)目錄下的表名所在的目錄巍虫。
我們前面例子創(chuàng)建了student表,導(dǎo)入了一個(gè)student.txt文件鳍刷。我們查看hdfs系統(tǒng)上Hive倉(cāng)庫(kù)目錄下的內(nèi)容占遥,會(huì)發(fā)現(xiàn)有如下目錄和文件,如:
[hadoop@localhost lib]$ hadoop fs -ls /user/hive/warehouse
Found 1 items
drwxr-xr-x - hadoop supergroup 0 2018-11-29 19:34 /user/hive/warehouse/student
[hadoop@localhost lib]$ hadoop fs -ls /user/hive/warehouse/student
Found 1 items
-rwxr-xr-x 1 hadoop supergroup 434 2018-11-29 19:28 /user/hive/warehouse/student/student.txt
可以看出输瓜,默認(rèn)的倉(cāng)庫(kù)目錄下有一個(gè)student目錄(目錄名與student表名一樣)瓦胎,student目錄下有一個(gè)student.txt文件,就是我們導(dǎo)入的文件尤揣。
(三)數(shù)據(jù)合法性檢查
通過(guò)前面的介紹我們知道搔啊,Hive表的定義信息只是對(duì)背后實(shí)際數(shù)據(jù)文件結(jié)構(gòu)的一種映射,反過(guò)來(lái)說(shuō)北戏,我們導(dǎo)入的數(shù)據(jù)文件也得和表的結(jié)構(gòu)相匹配负芋,否則查詢時(shí)就會(huì)報(bào)錯(cuò)。Hive對(duì)數(shù)據(jù)文件的合法性檢查不是在導(dǎo)入時(shí)檢查的嗜愈,而是在查詢時(shí)才會(huì)去判斷示罗。實(shí)際上我們也可以不用Hive的load命令導(dǎo)入數(shù)據(jù)文件,可直接通過(guò)hdfs的命令將文件上傳到相應(yīng)表的目錄下芝硬,這也是可以的蚜点。
六、運(yùn)行模式
Hive有多種運(yùn)行模式拌阴,用戶可以使用不同的方式來(lái)使用Hive绍绘。下面來(lái)一一介紹。
(一)單機(jī)模式
前面介紹的運(yùn)行hive程序,啟動(dòng)一個(gè)交互式命令行程序陪拘,實(shí)際背后運(yùn)行的是一個(gè)獨(dú)立的java進(jìn)程厂镇。我們通過(guò) jps命令可以查看到j(luò)ava進(jìn)程信息。
相當(dāng)于該java進(jìn)程即提供了交互界面讓用戶輸入hsql命令左刽,又包含了Hive執(zhí)行引擎以及metastore服務(wù)(訪問(wèn)存儲(chǔ)元數(shù)據(jù)的關(guān)系數(shù)據(jù)庫(kù))捺信。
需要說(shuō)明的是,在元數(shù)據(jù)內(nèi)嵌模式配置下(即默認(rèn)方式下)欠痴,只能允許啟動(dòng)一個(gè)單機(jī)進(jìn)程迄靠,也就是說(shuō)同時(shí)只能有一個(gè)用戶進(jìn)行Hive操作。
如果只是為了學(xué)習(xí)Hive喇辽,使用元數(shù)據(jù)內(nèi)嵌模式配置(即默認(rèn)配置)掌挚,然后啟動(dòng)單機(jī)模式(運(yùn)行hive程序進(jìn)行交互式操作)是最簡(jiǎn)單和方便的了。
(二)C/S模式
這種模式下菩咨,是將hive作為一個(gè)服務(wù)進(jìn)程啟動(dòng)(就是c/s架構(gòu)中的服務(wù)器程序)吠式,該服務(wù)器程序包含了Hive執(zhí)行引擎以及metastore服務(wù)。
用戶通過(guò)獨(dú)立的客戶端程序(可以是Hive自己提供的命令行程序抽米,也可以程序員自己編寫(xiě)的程序)來(lái)輸入hsql命令特占,發(fā)送給上面啟動(dòng)的Hive服務(wù)器程序,Hive服務(wù)器程序收到命令后執(zhí)行云茸,執(zhí)行后把結(jié)果返回給客戶端是目。實(shí)際就是一個(gè)典型的C/S架構(gòu)應(yīng)用。
這樣即使在元數(shù)據(jù)內(nèi)嵌模式配置下查辩,只能起一個(gè)服務(wù)器程序胖笛,但可以有多個(gè)客戶端程序操作网持,這樣就可以允許多用戶同時(shí)進(jìn)行操作了宜岛。
將Hive作為一個(gè)服務(wù)啟動(dòng)的方式是,在控制臺(tái)執(zhí)行:
hive --service hiveserver2
這時(shí)就啟動(dòng)了一個(gè)服務(wù)器程序功舀,默認(rèn)的監(jiān)聽(tīng)端口號(hào)是10000萍倡,我們可以通過(guò)linux命令查看相應(yīng)的進(jìn)程如:
[hadoop@localhost ~]$ netstat -nlp|grep :10000
(Not all processes could be identified, non-owned process info
will not be shown, you would have to be root to see it all.)
tcp 0 0 0.0.0.0:10000 0.0.0.0:* LISTEN 15366/java
可以看,啟動(dòng)的服務(wù)程序?qū)嶋H是一個(gè)java進(jìn)程辟汰,對(duì)應(yīng)的進(jìn)程號(hào)是15366列敲,該進(jìn)程的監(jiān)聽(tīng)的端口就是10000。
我們可以通過(guò)linux命令 kill 15366 來(lái)停止Hive服務(wù)程序帖汞。
上面的 hive --service hiveserver2 命令執(zhí)行后戴而,服務(wù)進(jìn)程堵塞在控制臺(tái)界面上,控制臺(tái)窗口不能關(guān)閉翩蘸,否則服務(wù)程序會(huì)退出所意。很多時(shí)候希望服務(wù)進(jìn)程留在后臺(tái)運(yùn)行,這樣控制臺(tái)就可以關(guān)閉了。在Linux下實(shí)現(xiàn)程序在后臺(tái)運(yùn)行很簡(jiǎn)單扶踊,在上面命令后加上 & 字符泄鹏,則該進(jìn)程就作為后臺(tái)進(jìn)程啟動(dòng)。如下面例子:
[hadoop@localhost bin]$ hive --service hiveserver2 &
[1] 15819
[hadoop@localhost bin]$ netstat -nlp|grep :10000
(Not all processes could be identified, non-owned process info
will not be shown, you would have to be root to see it all.)
tcp 0 0 0.0.0.0:10000 0.0.0.0:* LISTEN 15819/java
[hadoop@localhost bin]$
可以看出秧耗,執(zhí)行 hive --service hiveserver2 & 命令后备籽,程序不會(huì)堵塞,并且輸出了服務(wù)的進(jìn)程號(hào)分井,這里是15819车猬,與后面netstat查詢的結(jié)果一樣。這時(shí)我們把控制臺(tái)關(guān)閉對(duì)服務(wù)就沒(méi)影響了杂抽,服務(wù)在后臺(tái)運(yùn)行著诈唬。如果后面想關(guān)閉服務(wù),執(zhí)行l(wèi)inux命令 kill 15919即可缩麸。
Hive服務(wù)啟動(dòng)完畢后铸磅,我們就啟動(dòng)客戶端程序了,有多種運(yùn)行客戶端的方式杭朱。第一是使用Hive提供的beeline 命令行客戶端去連接hiveserver2服務(wù)器阅仔。運(yùn)行beeline的具體操作過(guò)程如下:
1、在控制臺(tái)運(yùn)行
hive --service beeline
2弧械、會(huì)出現(xiàn)beeline>提示符
3八酒、在提示符下輸入如下命令,注意不要漏了最前面的刃唐!
!connect jdbc:hive2://localhost:10000/default
4羞迷、會(huì)讓輸入用戶名和密碼,按提示輸入
5画饥、出現(xiàn)0: jdbc:hive2://localhost:10000/default> 提示符
6衔瓮、在上面提示符下就可以執(zhí)行各種hsql命令了。
具體操作過(guò)程如下:
[hadoop@localhost ~]$ hive --service beeline
Beeline version 1.2.2 by Apache Hive
beeline> !connect jdbc:hive2://localhost:10000/default
Connecting to jdbc:hive2://localhost:10000/default
Enter username for jdbc:hive2://localhost:10000/default: hadoop
Enter password for jdbc:hive2://localhost:10000/default: ******
Connected to: Apache Hive (version 1.2.2)
Driver: Hive JDBC (version 1.2.2)
Transaction isolation: TRANSACTION_REPEATABLE_READ
0: jdbc:hive2://localhost:10000/default> show tables;
OK
+-----------+--+
| tab_name |
+-----------+--+
| student |
+-----------+--+
1 row selected (1.611 seconds)
0: jdbc:hive2://localhost:10000/default>
因?yàn)閎eeline程序是通過(guò)jdbc與Hive服務(wù)器通訊的抖甘,所以上面第3步執(zhí)行的命令是一個(gè)標(biāo)準(zhǔn)的jdbc鏈接操作热鞍。
第二是編寫(xiě)程序去訪問(wèn)hiveserver2服務(wù)器,可以是jdbc客戶端程序衔彻,也可以odbc客戶端程序薇宠,還可以是thrift客戶端程序。我們通過(guò)一個(gè)jdbc的例子來(lái)看下艰额,例子的完整代碼如下:
package com.hiveexample;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
public class TestJdbc {
private static String driverName = "org.apache.hive.jdbc.hiveDriver";
private static String url = "jdbc:hive2://localhost:10000/default";
private static String username = "hadoop";
private static String password = "hadoop";
public static void main(String[] args) {
loadDriver();
Connection conn=getConn();
if(conn==null){
System.out.println("conn error,exit!");
return;
}
PreparedStatement stmt = null;
ResultSet rst = null;
String sql ="select * from student";
try {
stmt = conn.prepareStatement(sql);
rst = stmt.executeQuery();
while(rst.next()){
System.out.println(rst.getString(1));
}
}catch (SQLException e) {
e.printStackTrace();
} finally {
closeConn(conn, stmt, rst);
}
}
private static void loadDriver() {
try {
Class.forName(driverName);
} catch (ClassNotFoundException e) {
e.printStackTrace();
System.exit(1);
}
}
public static Connection getConn() {
Connection conn = null;
try {
Class.forName(driverName);
conn = DriverManager.getConnection(url, username, password);
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
}
return conn;
}
private static void closeConn(Connection conn, PreparedStatement stmt, ResultSet rst) {
if (rst != null)
try {
rst.close();
rst = null;
} catch (SQLException e) {
}
if (stmt != null)
try {
stmt.close();
stmt = null;
} catch (SQLException e) {
}
if (conn != null)
try {
conn.close();
conn = null;
} catch (SQLException e) {
}
}
}
可以看出澄港,上面就是一個(gè)普通的java類,通過(guò)jdbc操作數(shù)據(jù)庫(kù)柄沮。編譯該類不依賴任何第三方j(luò)ar回梧。但運(yùn)行時(shí)逐工,需要依賴Hive的jdbc驅(qū)動(dòng)。為了簡(jiǎn)單漂辐,我們可以把編譯后的class打成Jar包泪喊,然后利用Hive提供的jar服務(wù)來(lái)運(yùn)行程序。假設(shè)編譯后的class打成的Jar包名為hiveexample.jar,則該jar包的當(dāng)前目錄下髓涯,在控制臺(tái)執(zhí)行如下命令袒啼,即可運(yùn)行該jdbc程序。
hive --service jar hiveexample.jar com.hiveexample.TestJdbc
運(yùn)行hive --service jar 和運(yùn)行hadoop jar類似纬纪,只是前者會(huì)同時(shí)把Hadoop的類路徑和Hive的類路徑同時(shí)包含進(jìn)來(lái)蚓再,省的我們自己去選擇運(yùn)行程序時(shí)依賴的jar包路徑。
(三)web模式
Hive框架提供了一種方式包各,可以啟動(dòng)一個(gè)web服務(wù)器摘仅,用戶通過(guò)瀏覽器發(fā)送請(qǐng)求到web服務(wù)器,web服務(wù)器完成相關(guān)的Hive操作问畅。具體如何配置和使用web模式娃属,本文不作介紹。
本文只是對(duì)Hive最基本的知識(shí)的一個(gè)學(xué)習(xí)總結(jié)护姆,很多更多高級(jí)和詳細(xì)的內(nèi)容沒(méi)有在文中體現(xiàn)矾端。