`

hive中order by,sort by, distribute by, cluster by作用以及用法

 
阅读更多

1. order by

    Hive中的order by跟传统的sql语言中的order by作用是一样的,会对查询的结果做一次全局排序,所以说,只有hive的sql中制定了order by所有的数据都会到同一个reducer进行处理(不管有多少map,也不管文件有多少的block只会启动一个reducer)。但是对于大量数据这将会消耗很长的时间去执行。
    这里跟传统的sql还有一点区别:如果指定了hive.mapred.mode=strict(默认值是nonstrict),这时就必须指定limit来限制输出条数,原因是:所有的数据都会在同一个reducer端进行,数据量大的情况下可能不能出结果,那么在这样的严格模式下,必须指定输出的条数。

2. sort by

    Hive中指定了sort by,那么在每个reducer端都会做排序,也就是说保证了局部有序(每个reducer出来的数据是有序的,但是不能保证所有的数据是有序的,除非只有一个reducer),好处是:执行了局部排序之后可以为接下去的全局排序提高不少的效率(其实就是做一次归并排序就可以做到全局排序了)。

3. distribute by和sort by一起使用

    ditribute by是控制map的输出在reducer是如何划分的,举个例子,我们有一张表,mid是指这个store所属的商户,money是这个商户的盈利,name是这个store的名字

store:

 

mid money name
AA 15.0 商店1
AA 20.0 商店2
BB 22.0 商店3
CC 44.0 商店4

 

    执行hive语句:

[delphi] view plaincopy在CODE上查看代码片派生到我的代码片
 
  1. select mid, money, name from store distribute by mid sort by mid asc, money asc  

我们所有的mid相同的数据会被送到同一个reducer去处理,这就是因为指定了distribute by mid,这样的话就可以统计出每个商户中各个商店盈利的排序了(这个肯定是全局有序的,因为相同的商户会放到同一个reducer去处理)。这里需要注意的是distribute by必须要写在sort by之前。

 

4. cluster by

    cluster by的功能就是distribute by和sort by相结合,如下2个语句是等价的:

    

[sql] view plaincopy在CODE上查看代码片派生到我的代码片
 
  1. select mid, money, name from store cluster by mid  
[sql] view plaincopy在CODE上查看代码片派生到我的代码片
 
  1. select mid, money, name from store distribute by mid sort by mid  

    如果需要获得与3中语句一样的效果:

 

 

[sql] view plaincopy在CODE上查看代码片派生到我的代码片
 
  1. select mid, money, name from store cluster by mid sort by money  

    注意被cluster by指定的列只能是降序,不能指定asc和desc。

分享到:
评论

相关推荐

    Hive查询优化:Sort By、Order By、Cluster By、Distribute深入解析

    3. **数据抽象**:Hive使用表和分区等概念来抽象底层数据存储,使得用户可以像操作传统数据库一样操作Hadoop集群中的数据。 4. **扩展性**:Hive设计用于处理大规模数据集,可以水平扩展以适应更大的数据量。 5. **...

    Hive拉拉扯扯的order by,sort by,distribute by, cluster by

    Hive支持两个层面的排序: 全局排序 部分排序 全局排序用 order by col [ASC | DESC] 实现,效果和传统的RDMS一样,...鉴于此,Hive有一些自己特定,比如order by的实现需要把所有数据汇集到一个reducer中处理,如果数

    【63课时完整版】大数据实践HIVE详解及实战

    19.Hive中order by、sort by、distribute by与cluster by的使用 20.Hive中分析函数与窗口函数 21.Hive中UDF的介绍 22.Hive中使用自定义UDF实现日期格式转换 23. HiveServer2的介绍及三种连接方式 24.Hive元数据、...

    大数据面试 Hive 八股文

    7. **Hive的cluster by、sort by、distribute by、order by的区别** - **order by**:全局排序,所有数据经过Reducer后按指定列排序。 - **sort by**:局部排序,每个Mapper输出按指定列排序,但不同Mapper之间不...

    Hive教程.pdf

    - `SELECT * FROM table_name DISTRIBUTE BY column_name SORT BY column_name [ASC | DESC];` - **DistributeBy和SortBy**: - 在MapReduce作业中控制数据的分布和排序方式。 - **ClusterBy**: - `SELECT * FROM ...

    《企业级Hive实战课程》大纲

    - 排序操作(ORDER BY、SORT BY、DISTRIBUTE BY、CLUSTER BY); - 复合数据类型(ARRAY、MAP、STRUCT)的使用技巧。 5. **Hive高级特性** - 索引创建与管理; - HiveServer2/beeline的使用; - Java操作Hive...

    hive 简明教程

    Hive还提供了排序操作,支持`ORDER BY`、`SORT BY`、`DISTRIBUTE BY`和`CLUSTER BY`等排序方式,以适应不同的业务场景。 Hive内置函数包括用于处理数据的函数,例如`explode`、`collect_set`、`collect_list`等。...

    大数据组件 Hive 面试题 + Hive 高频面试题

    `Cluster By`则兼备了`Distribute By`和`Sort By`的功能,但仅支持升序排序。 窗口函数是数据分析中的利器,如`RANK()`、`DENSE_RANK()`和`ROW_NUMBER()`。它们在`OVER()`定义的窗口内工作,可以实现动态排序。`LAG...

    大数据学习:Hive数据查询语言.pdf

    [CLUSTER BY col_list | [DISTRIBUTE BY col_list] [SORT BY col_list] ] [LIMIT number] ``` 其中,WITH CommonTableExpression 是可选的,表示公用表达式;select_expr 表示查询语句的表达式;LIMIT number 是可...

    精品课程推荐 大数据与云计算教程课件 优质大数据课程 17.Hive查询(共32页).pptx

    Hive提供了ORDER BY用于全局排序,但对大数据集可能效率较低,这时可以使用SORT BY进行局部排序,配合DISTRIBUTE BY或CLUSTER BY进行数据分布和预处理,以优化聚集操作。此外,Hive的JOIN操作简化了数据连接,支持内...

    HiveSQL优化手册

    - **Cluster By**:当`Distribute By`和`Sort By`字段相同时,可以使用`Cluster By`代替,简化写法的同时实现相同的效果。 2. **合理设置Map/Reduce Task数量** - **减少Map数量**:通过小文件合并或调整JVM重用...

    Hive中查询操作

    在Hive中,查询操作是数据处理的核心,它允许用户从大数据存储中提取所需的信息。以下将详细解析Hive查询语法及其基本查询方法。 一、Hive查询语法 Hive的查询语句遵循标准SQL的基本结构,但也有一些Hive特有的扩展...

    大数据 虚拟机 Linux VM复习题库:题库包括了60题选择题、10题填空题、10题判断题、2题简答题,助你度过期末复习

    - `cluster by`等同于`sort by`+`distribute by`,支持正序排序。 9. **Hive与传统数据库的差异**: Hive基于Hadoop,数据存储在HDFS,适用于读多写少的场景,查询语言HQL类似SQL但处理速度较慢。 10. **Hive...

    Apache Hive面试题

    - **特点**:特殊形式的`DISTRIBUTE BY` + `SORT BY`,同时具备数据分布和排序功能。 - **限制**:仅支持降序排序,不支持ASC或DESC指定。 #### 四、Hive大表Join小表的优化方法 1. **小表前置**: - **方法**...

    BigData-Interview:

    发一条内推消息,社招、实习生欢迎投递 字节跳动校招内推码: 3UWFMRS 投递链接: 社招: 大数据面试题汇总与答案分享 Spark ...hive中 sort by / order by / cluster by / distribute by 的区别 hive的me

    项目笔记1

    【Hive中的sort by, order by, cluster by, distribute by】 - `sort by`:在每个分区内部对数据进行排序,不保证全局排序。 - `order by`:全局排序,需要全表扫描,效率较低。 - `cluster by`:类似于`sort by`,...

Global site tag (gtag.js) - Google Analytics