您好,登錄后才能下訂單哦!
小編給大家分享一下Hive如何分組取Top N,相信大部分人都還不怎么了解,因此分享這篇文章給大家參考一下,希望大家閱讀完這篇文章后大有收獲,下面讓我們一起去了解一下吧!
Hive在0.11.0版本開始加入了row_number、rank、dense_rank分析函數,可以查詢分組排序后的top值
row_number() over ([partition col1] [order by col2] )
rank() over ( [partition col1] [order by col2] )
dense_rank() over ( [partition col1] [order by col2] )
它們都是根據col1字段分組,然后對col2字段進行排序,對排序后的每行生成一個行號,這個行號從1開始遞增
col1、col2都可以是多個字段,用','分隔
1)row_number:不管col2字段的值是否相等,行號一直遞增, 比如:有兩條記錄的值相等,但一個是第一,一個是第二
2)rank:上下兩條記錄的col2相等時,記錄的行號是一樣的,但下一個col2值的行號遞增N(N是重復的次數),比如:有兩條并列第一,下一個是第三,沒有第二
3)dense_rank:上下兩條記錄的col2相等時,下一個col2值的行號遞增1, 比如:有兩條并列第一,下一個是第二
row_number可以實現分頁查詢
創建表
create table t(name string, sub string, score int) row format delimited fields terminated by '\t';
數據在附件的a.txt里
a chinese 98 a english 90 d chinese 88 c english 82 c math 98 b math 89 b chinese 79 z english 90 z math 89 z chinese 80 e math 99 e english 87 d english 90 加載數據 load data local inpath '/home/hadoop/hive-example/a.txt' into table tb4;
分組排序
--row_number select *, row_number() over (partition by sub order by score) as od from t; --rank select *, rank() over (partition by sub order by score) as od from t; --dense_ran select *, dense_rank() over (partition by sub order by score desc) from t;
--統計每個學科的前三名 select * from (select *, row_number() over (partition by sub order by score desc) as od from t ) t where od<=3; --語文成績是80分的排名是多少 select od from (select *, row_number() over (partition by sub order by score desc) as od from t ) t where sub='chinese' and score=80; --分頁查詢 select * from (select *, row_number() over () as rn from t) t1 where rn between 1 and 5;
以上是“Hive如何分組取Top N”這篇文章的所有內容,感謝各位的閱讀!相信大家都有了一定的了解,希望分享的內容對大家有所幫助,如果還想學習更多知識,歡迎關注億速云行業資訊頻道!
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。