python 實(shí)現(xiàn) hive中類似 lateral view explode的功能示例
背景:加入現(xiàn)在有這樣的數(shù)據(jù),可能一條ocr代表兩個(gè)label,并且label通過','分隔。我們想把數(shù)據(jù)轉(zhuǎn)換成下面的。
原始數(shù)據(jù):
label ocr 日常行車服務(wù),汽車資訊 去加油站,加完油后直接離開?最開心的可能是加油站的工作人員 社會民生 已致2死20傷 !景區(qū)突遭塵卷風(fēng)襲擊,孩子被卷上天!現(xiàn)場畫面曝光目標(biāo)數(shù)據(jù):
label ocr 日常行車服務(wù) 去加油站,加完油后直接離開?最開心的可能是加油站的工作人員 汽車資訊 去加油站,加完油后直接離開?最開心的可能是加油站的工作人員 社會民生 已致2死20傷 !景區(qū)突遭塵卷風(fēng)襲擊,孩子被卷上天!現(xiàn)場畫面曝光實(shí)現(xiàn)辦法:
1.通過hive代碼:
select ocr,split(tag_info,’,’) labelfrom ( select label,ocr from t1 lateral view explode(split(label,’,’)) TableName as tag_info ) t;
要注意的是一定要添加 t 語句另命名。
2.通過python代碼:
df0 = pd.DataFrame({’A’:[[1,2],[5,6]],’B’:[10,-20]})df0 = dfdf0.columns = [’A’,’B’]rows = []for i, row in df0.iterrows(): for a in row.A.split(','): rows.append((a, row.B))df222 = pd.DataFrame(rows, columns=df.columns)df222
補(bǔ)充知識:hive中的lateral view(側(cè)視圖) 與 explode函數(shù)的使用
今天偶然間發(fā)現(xiàn)了一個(gè)hive中列轉(zhuǎn)行的小題目,需要用到lateral view 和 explode函數(shù),剛好借這題說說lateral view 與 explode函數(shù)的使用。
題目是這樣:
原數(shù)據(jù)表如下圖
movie category 《疑犯追蹤》 懸疑,動作,科幻,劇情 《Lie to me》 懸疑,警匪,動作,心理,劇情 《戰(zhàn)狼2》 戰(zhàn)爭,動作,災(zāi)難需求:將電影分類中的數(shù)組數(shù)據(jù)展開。
結(jié)果如下:
《疑犯追蹤》 懸疑《疑犯追蹤》 動作《疑犯追蹤》 科幻《疑犯追蹤》 劇情《Lie to me》 懸疑《Lie to me》 警匪
先簡單聊幾句理論:explode與lateral view在關(guān)系型數(shù)據(jù)庫中本身是不該出現(xiàn)的,因?yàn)樗某霈F(xiàn)本身就是在操作不滿足第一范式的數(shù)據(jù)(每個(gè)屬性都不可再分),本身已經(jīng)違背了數(shù)據(jù)庫的設(shè)計(jì)原理(不論是業(yè)務(wù)系統(tǒng)還是數(shù)據(jù)倉庫系統(tǒng)),不過大數(shù)據(jù)技術(shù)普及后,很多類似pv,uv的數(shù)據(jù),在業(yè)務(wù)系統(tǒng)中是存貯在非關(guān)系型數(shù)據(jù)庫中,用json存儲的概率比較大,直接導(dǎo)入hive為基礎(chǔ)的數(shù)倉系統(tǒng)中,就需要經(jīng)過ETL過程解析這類數(shù)據(jù),explode與lateral view在這種場景下大顯身手。
explode作用是處理map結(jié)構(gòu)的字段,使用案例如下:
//建表語句create table movie_info(movie string,category array<string>)row format delimited fields terminated by ’t’collection items terminated by ’,’;//加載數(shù)據(jù)load data local inpath ’/opt/data/movie.txt’ into table movie_info;
看下explode函數(shù)效果,以拆解category為例,可與原數(shù)據(jù)表結(jié)構(gòu)對比。
select explode(category) from movie_info;
LATERAL VIEW的使用:
用法:
LATERAL VIEW udtf(expression) tableAlias AS columnAlias
解釋:用于和split, explode等UDTF一起使用,它能夠?qū)⒁涣袛?shù)據(jù)拆成多行數(shù)據(jù),在此基礎(chǔ)上可以對拆分后的數(shù)據(jù)進(jìn)行聚合。
select movie,category_namefrom movie_infolateral view explode(category) table_emp as category_name;
效果如下:
其中l(wèi)ateral view explode(category) table_emp相當(dāng)于一個(gè)虛擬表,與原表movie_info笛卡爾積關(guān)聯(lián),也可以多重使用。那么問題就這樣解決了。
以上這篇python 實(shí)現(xiàn) hive中類似 lateral view explode的功能示例就是小編分享給大家的全部內(nèi)容了,希望能給大家一個(gè)參考,也希望大家多多支持好吧啦網(wǎng)。
相關(guān)文章:
1. chat.asp聊天程序的編寫方法2. JSP之表單提交get和post的區(qū)別詳解及實(shí)例3. 利用FastReport傳遞圖片參數(shù)在報(bào)表上展示簽名信息的實(shí)現(xiàn)方法4. PHP循環(huán)與分支知識點(diǎn)梳理5. Ajax請求超時(shí)與網(wǎng)絡(luò)異常處理圖文詳解6. JSP+Servlet實(shí)現(xiàn)文件上傳到服務(wù)器功能7. jsp實(shí)現(xiàn)textarea中的文字保存換行空格存到數(shù)據(jù)庫的方法8. ASP中格式化時(shí)間短日期補(bǔ)0變兩位長日期的方法9. JavaWeb Servlet中url-pattern的使用10. jsp EL表達(dá)式詳解
