小编给大家分享一下Hive中分组Limit非UDF方案的示例分析,相信大部分人都还不怎么了解,因此分享这篇文章给大家参考一下,希望大家阅读完这篇文章后大有收获,下面让我们一起去了解一下吧!
描述: id (自增),type (aaa, bbb,ccc ,ddd),status(ok,error) 三个字段,每个type,筛选status='ok'的并且id最小的那一条记录。
create table having_test (id int(11), type varchar(50),status varchar(50));
mysql> select * from having_test;
+------+------+--------+
| id | type | status |
+------+------+--------+
| 1 | aaa | ok |
| 2 | aaa | error |
| 3 | aaa | ok |
| 4 | bbb | ok |
| 5 | ccc | error |
| 6 | ccc | ok |
| 7 | ddd | error |
+------+------+--------+
mysql> select * from having_test where status='ok' group by type having min(id);
+------+------+--------+
| id | type | status |
+------+------+--------+
| 1 | aaa | ok |
| 4 | bbb | ok |
| 6 | ccc | ok |
+------+------+--------+
mysql中很简单就实现了,先 group 然后having ,但是hive上不是完全支持sql语法的,在hive上会不会这么简单呢,答案是否定的。
create table tmp_wjk_having_test (id int, type string, status string) ROW FORMAT DELIMITED FIELDS TERMINATED BY '\t' ;
load data local inpath '/tmp/load.csv' overwrite into table tmp_wjk_having_test;
select * from tmp_wjk_having_test;
1 aaa ok
2 aaa error
3 aaa ok
4 bbb ok
5 ccc error
6 ccc ok
7 ddd error
select * from tmp_wjk_having_test where status='ok' group by type having min(id);
FAILED: Error in semantic analysis: Line 1:73 Expression not in GROUP BY key 'id'
# hive 不支持这种写法。还是要用子查询
select * from tmp_wjk_having_test t1 join (
select min(id) id from tmp_wjk_having_test where status='ok' group by type) t2
on t1.id=t2.id ;
1 aaa ok 1
4 bbb ok 4
6 ccc ok 6
子查询对于小数据集没有影响,但是应用到大数据上最好的是只过一边表,然后就拿出结果。所以还在想新的方案。
select *,min(id) ii from tmp_wjk_having_test where status='ok' group by type ;
aaa 1 1
bbb 4 4
ccc 6 6
这种方案可行。问题点:
1. 为什么min(id)的条件明明是写到了select 中非where ,但是确起到了筛选的作用?
2. 为什么明明是select * ,min(id) 但是最后是拿到了3列(type , id , min(id) ), 如果写成 select type ,min(id) 就只拿到2列( type ,min(id) ) .
select type,min(id) ii from tmp_wjk_having_test where status='ok' group by type;
aaa 1
bbb 4
ccc 6
++++更新 2014.11.11
3、一般可行方案:
2列 : select type,min(id) ii from tmp_wjk_having_test where status='ok' group by type;
多列:select t1.* from having_test t1 join (select name,min(age) mm from having_test group by name ) t2 on t1.name = t2.name and t1.age=t2.mm ;
以上是“Hive中分组Limit非UDF方案的示例分析”这篇文章的所有内容,感谢各位的阅读!相信大家都有了一定的了解,希望分享的内容对大家有所帮助,如果还想学习更多知识,欢迎关注亿速云行业资讯频道!
亿速云「云服务器」,即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘,价格低至29元/月。点击查看>>
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。
原文链接:https://my.oschina.net/wangjiankui/blog/161664