Hive优化之多count(distinct)

本篇介绍Hive三种方法,优化多count(distinct )


先上待优化代码:

select count(distinct sid) as sid

      ,count(distinct entity_id) as entity_id

      ,count(distinct billing_status_code) as billing_status_code

  from c_detail

where cal_dt='2020-03-30';

因为count(disticnt)需要去重操作,需要将所有数据放到同一task去重,只会产生一个reduce task。如果数据量过大,成为性能瓶颈


两种普通操作:

一、负载均衡法(将一步到位转成两步 ①去重  ②count)

select max(case when col = 'sid' then cn end) as sid

      ,max(case when col = 'entity_id' then cn end)  as entity_id

  ,max(case when col = 'billing_status_code' then cn end) as billing_status_code

  from

(select count(1) as cn,'sid' as col from (select sid from c_detail where cal_dt='2020-03-30' group by sid)a union all

select count(1) as cn,'entity_id' as col from (select entity_id from c_detail where cal_dt='2020-03-30' group by entity_id)a union all

select count(1) as cn,'billing_status_code' as col from (select billing_status_code from c_detail where cal_dt='2020-03-30' group by billing_status_code)a )b ;

优点:负载均衡,完全解决一个reduce产生的性能瓶颈

缺点:写起来比较麻烦,需要每个字段单独去重union all到一起。最后还得行转列,如果几十个count(distinct) 写死也不为过。


二、省事法 ①先组合去重减少数据量 ②count(distinct) 第二步仍然是一个reduce,但是数据量减少了。

select count(distinct sid),count(distinct entity_id),count(distinct billing_status_code)

  from

(select sid,entity_id,billing_status_code

  from c_detail

where cal_dt='2020-03-30'

group by sid,entity_id,billing_status_code)a;

优点:写起来简单

缺点:如果去重后数据量仍然非常大,还是跑不出来,如果sid是用户id基数很大,其他两列基数很小,这个去重效果就微乎其微,需要一二组合使用

组合折中法

select count(distinct sid),count(distinct entity_id),count(distinct billing_status_code)

  from

(select  entity_id,billing_status_code from c_detail

where cal_dt='2020-03-30'

group by entity_id,billing_status_code)a

join (select  count(1) as sid from (select  distinct sid from c_detail

where cal_dt='2020-03-30') b)c on 1=1;

如果基数低字段较多的话,组合使用写起来也非常烦


三、高端大气grouping sets法,既写起来方便,又能负载均衡

select count(case when entity_id is null and billing_status_code is null then 1 end) as sid

      ,count(case when sid is null and billing_status_code is null then 1 end) as entity_id

  ,count(case when sid is null and entity_id is null then 1 end) as billing_status_code

  from

(select sid,entity_id,billing_status_code

  from c_detail

group by sid,entity_id,billing_status_code

grouping sets((sid),(entity_id),(billing_status_code)))a;

相当于使用grouping sets来代替 无数的group by+union all

缺点:grouping sets组过多会产生性能问题,grouping sets语法逻辑,会产生什么样的性能问题呢?请看下篇 Hive多维度聚合

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 217,907评论 6 506
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 92,987评论 3 395
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 164,298评论 0 354
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 58,586评论 1 293
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 67,633评论 6 392
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 51,488评论 1 302
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 40,275评论 3 418
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 39,176评论 0 276
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 45,619评论 1 314
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,819评论 3 336
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,932评论 1 348
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 35,655评论 5 346
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 41,265评论 3 329
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,871评论 0 22
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,994评论 1 269
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 48,095评论 3 370
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 44,884评论 2 354

推荐阅读更多精彩内容