小編給大家分享一下hive中order by,distribute by,sort by,cluster by有什么用,相信大部分人都還不怎么了解,因此分享這篇文章給大家參考一下,希望大家閱讀完這篇文章后大有收獲,下面讓我們一起去了解一下吧!
創(chuàng)新互聯(lián)長期為1000多家客戶提供的網(wǎng)站建設服務,團隊從業(yè)經(jīng)驗10年,關(guān)注不同地域、不同群體,并針對不同對象提供差異化的產(chǎn)品和服務;打造開放共贏平臺,與合作伙伴共同營造健康的互聯(lián)網(wǎng)生態(tài)環(huán)境。為興和企業(yè)提供專業(yè)的做網(wǎng)站、網(wǎng)站制作,興和網(wǎng)站改版等技術(shù)服務。擁有十載豐富建站經(jīng)驗和眾多成功案例,為您定制開發(fā)。
order by,distribute by,sort by,cluster by 查詢使用說明
// 根據(jù)年份和氣溫對氣象數(shù)據(jù)進行排序,以確保所有具有相同年份的行最終都在一個reducer分區(qū)中 // 一個reduce(海量數(shù)據(jù),速度很慢) select year, temperature order by year asc, temperature desc limit 100; // 多個reduce(海量數(shù)據(jù),速度很快) select year, temperature distribute by year sort by year asc, temperature desc limit 100;
order by (全局排序 )
order by 會對輸入做全局排序,因此只有一個reducer(多個reducer無法保證全局有序)
只有一個reducer,會導致當輸入規(guī)模較大時,需要較長的計算時間。
在hive.mapred.mode=strict模式下,強制必須添加limit限制,這么做的目的是減少reducer數(shù)據(jù)規(guī)模
例如,當限制limit 100時, 如果map的個數(shù)為50, 則reducer的輸入規(guī)模為100*50
distribute by (類似于分桶)
根據(jù)distribute by指定的字段對數(shù)據(jù)進行劃分到不同的輸出reduce 文件中。
sort by (類似于桶內(nèi)排序)
sort by不是全局排序,其在數(shù)據(jù)進入reducer前完成排序。
因此,如果用sort by進行排序,并且設置mapred.reduce.tasks>1, 則sort by只保證每個reducer的輸出有序,不保證全局有序。
cluster by
cluster by 除了具有 distribute by 的功能外還兼具 sort by 的功能。
但是排序只能是倒序排序,不能指定排序規(guī)則為asc 或者desc。
因此,常常認為cluster by = distribute by + sort by
以上是“hive中order by,distribute by,sort by,cluster by有什么用”這篇文章的所有內(nèi)容,感謝各位的閱讀!相信大家都有了一定的了解,希望分享的內(nèi)容對大家有所幫助,如果還想學習更多知識,歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道!