使用子查询可提升 COUNT DISTINCT 速度 50 倍

摘要:
使用唯一的pgAdminIII生成解释图形。让我们从我们一直使用的一个简单查询开始:哪个图表的用户流量最大?当查询一千万行数据时,需要48秒。我们不需要使用仪表板进行组聚合Name,我们也可以先对数据库进行聚合。连接前:12345678910111213选择dashboards.name,log_counts.ctfromdashboardsjonaslog_countsonlog_counts.dashboard_id=dashboards.idorderbylog_count。Ctdesc现在运行查询20秒,增加了2.4倍。这比上述查询快28倍,比原始查询快68倍。与数据总量相比,不同的数量也很小。下次遇到长时间运行的countdistinct时,请尝试一些子查询来减轻负载。

注:这些技术是通用的,只不过我们选择使用Postgres的语法。使用独特的pgAdminIII生成解释图形。

  很有用,但太慢

  Count distinct是SQL分析时的祸根,因此它是我第一篇博客的不二选择。

  首先:如果你有一个大的且能够容忍不精确的数据集,那像HyperLogLog这样的概率计数器应该是你最好的选择。(我们会在以后的博客中谈到HyperLogLog。)但对于需要快速、精准答案的查询,一些简单的子查询可以节省你很多时间。

  让我们以我们一直使用的一个简单查询开始:哪个图表的用户访问量最大?

1
2
3
4
5
6
7
select 
  dashboards.name
  count(distinct time_on_site_logs.user_id)
from time_on_site_logs 
join dashboards on time_on_site_logs.dashboard_id = dashboards.id
group by name 
order by count desc

  首先,我们假设user_id和dashboard_id上已经设置了索引,且有比图表和用户数多得多的日志条目。

  一千万行数据时,查询需要48秒。要知道原因让我们看一下SQL解析:

Explain Slow

  它慢是因为数据库遍历了所有日志以及所有的图表,然后join它们,再将它们排序,这些都在真正的group和分组和聚合工作之前。

  先聚合,然后Join

  group-聚合后的任何工作代价都要低,因为数据量会更小。group-聚合时我们不需使用dashboards.name,我们也可以先在数据库上做聚集,在join之前:

1
2
3
4
5
6
7
8
9
10
11
12
13
select
  dashboards.name,
  log_counts.ct
from dashboards
join (
  select
    dashboard_id,
    count(distinct user_id) as ct
  from time_on_site_logs 
  group by dashboard_id
as log_counts 
on log_counts.dashboard_id = dashboards.id
order by log_counts.ct desc

  现在查询运行了20秒,提升了2.4倍。再次通过解析来看一下原因:

使用子查询可提升 COUNT DISTINCT 速度 50 倍第2张

  正如设计的,group-聚合在join之前。而且,额外的我们可以利用time_on_site_logs表里的索引。

  首先,缩小数据集

  我们可以做的更好。通过在整个日志表上group-聚合,我们处理了数据库中很多不必要的数据。Count distinct为每个group生成一个哈希——在本次环境中为每个dashboard_id——来跟踪哪些bucket中的哪些值已经检查过。

  我们可以预先计算差异,而不是处理全部数据,这样只需要一个哈希集合。然后我们在此基础上做一个简单的聚集即可。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
select
  dashboards.name,
  log_counts.ct
from dashboards 
join (
  select distinct_logs.dashboard_id, 
  count(1) as ct
  from (
    select distinct dashboard_id, user_id
    from time_on_site_logs
  as distinct_logs
  group by distinct_logs.dashboard_id
as log_counts 
on log_counts.dashboard_id = dashboards.id
order by log_counts.ct desc

  我们采取内部的count-distinct-group,然后将数据拆成两部分分成两块。第一块计算distinct (dashboard_id, user_id) 。第二块在它们基础上运行一个简单group-count。跟上面一样,最后再join。

使用子查询可提升 COUNT DISTINCT 速度 50 倍第3张

  呵呵,大发现:这样只需要0.7秒!这比上面的查询快28倍,比原来的快了68倍

  通常,数据大小和类型很重要。上面的例子受益于基数中没多少换算。distinct (user_id, dashboard_id)相对于数据总量来说数量也很少。不同的对数越多,用来group和计数的唯一数据就越多——代价便会越来越大。

  下一遇到长时间运行的count distinct时,尝试一些子查询来减负吧。

  原文地址:https://periscope.io/blog/use-subqueries-to-count-distinct-50x-faster.html

免责声明:文章转载自《使用子查询可提升 COUNT DISTINCT 速度 50 倍》仅用于学习参考。如对内容有疑问,请及时联系本站处理。

上篇超几何分布和二项分布深入了解Java ClassLoader、Bytecode 、ASM、cglib(II)下篇

宿迁高防,2C2G15M,22元/月;香港BGP,2C5G5M,25元/月 雨云优惠码:MjYwNzM=

相关文章

SQL Server 聚合函数 (方差和标准差)

方差和标准差只能用于数值型的列,NULL值会被忽略。 一,方差和标准差 总体方差的计算公式: 在实际测试中,总体的均数难以得到,需要使用样本统计量代替总体参数,需要对数据进行校正,样本方差计算公式: 方差的语法: VAR ( [ ALL | DISTINCT ] expression ) VARP ( [ ALL | DISTINCT ] expre...

HIVE优化学习笔记

概述 之前写过关于hive的已经有两篇随笔了,但是作者依然还是一枚小白,现在把那些杂七杂八的总结一下,供以后查阅和总结。今天的文章介绍一下hive的优化。hive是好多公司都在使用的东西,也有好多大公司进行定制化二次优化,比如鹅厂的Thive等。所以学习hive至关重要,本文只针对大众版免费开源的hive。官网地址:http://hive.apache.o...

SQL -去重Group by 和Distinct的效率

经实际测试,同等条件下,5千万条数据,Distinct比Group by效率高,但是,这是有条件的,这五千万条数据中不重复的仅仅有三十多万条,这意味着,五千万条中基本都是重复数据。 为了验证,重复数据是否对其有影响,本人针对80万条数据进行测试: 下面是对CustomerId去重,CustomerId的重复项及其多,80万条中仅仅50条不重复的。可以看到,...

hive函数之~集合统计函数

1、个数统计函数: count *** 语法: count(*), count(expr), count(DISTINCT expr[, expr_.])返回值: int说明: count(*)统计检索出的行的个数,包括NULL值的行;count(expr)返回指定字段的非空值的个数;count(DISTINCT expr[, expr_.])返回指定字段...

c# lambda distinct

在写程序的时候会遇见这样的问题,那就是去重,有什么方法更快呢。当去重时,首先想到的是自己写代码,代码大概如下: private static void distinctListIntTest() { Console.WriteLine("未去重"); List<int> li...

oracle教程:PLSQL常用方法汇总

oracle教程:PLSQL常用方法汇总 在SQLPLUS下,实现中-英字符集转换alter session set nls_language='AMERICAN';alter session set nls_language='SIMPLIFIED CHINESE';主要知识点:一、有关表的操作1)建表 create table test as sel...