hivesql中常用函数
时间: 2023-11-04 10:05:36 AIGC 浏览: 217
HiveSQL中常用的函数包括以下几类:
1. 聚合函数:如SUM、AVG、COUNT等,用于对数据进行统计分析。
2. 字符串函数:如CONCAT、SUBSTR、TRIM等,用于对字符串进行操作。
3. 数学函数:如ABS、CEIL、FLOOR等,用于对数字进行操作。
4. 日期函数:如YEAR、MONTH、DAY等,用于对日期进行操作。
5. 条件函数:如CASE、IF、COALESCE等,用于根据条件进行判断和处理。
6. 开窗函数:如ROW_NUMBER、RANK、DENSE_RANK等,用于对数据进行排序和分组。
7. 其他函数:如UDF、UDAF、UDTF等,用于自定义函数和聚合函数。
其中,COALESCE()函数在HiveSQL中也是常用的空值处理函数,而开窗函数在HiveSQL中也有类似于引用中提到的OVER子句的用法。
相关问题
hiveSQL常用的函数
HiveSQL常用的函数包括:
1. 聚合函数:如SUM、AVG、COUNT、MAX、MIN等,用于对数据进行统计分析。
2. 字符串函数:如CONCAT、SUBSTR、TRIM、LOWER、UPPER等,用于对字符串进行操作。
3. 数学函数:如ABS、CEIL、FLOOR、ROUND、POWER等,用于对数字进行计算。
4. 时间函数:如YEAR、MONTH、DAY、HOUR、MINUTE等,用于对时间进行处理。
5. 条件函数:如CASE WHEN、IF、COALESCE、NULLIF等,用于对数据进行条件判断和处理。
6. 集合函数:如COLLECT_SET、COLLECT_LIST、MAP、STRUCT等,用于对复杂数据类型进行处理。
7. 窗口函数:如RANK、DENSE_RANK、ROW_NUMBER、LEAD、LAG等,用于对数据进行分组和排序操作。
这些函数可以帮助我们在HiveSQL中进行数据处理和分析。
hivesql常用函数
### HiveSQL 常用内置函数
#### 数学函数
Hive 提供了一系列用于数值计算的数学函数。这些函数可以处理基本算术运算以及更复杂的数学操作。
- `ABS(x)` 返回绝对值[^2]
- `CEIL(x)` 或者 `CEILING(x)` 向上取整返回最小的大于等于 x 的整数[^2]
- `FLOOR(x)` 向下取整返回最大的小于等于 x 的整数
```sql
SELECT ABS(-10), CEIL(3.14), FLOOR(3.14);
```
#### 字符串函数
字符串处理是数据分析中的常见需求,因此 Hive 支持多种字符串操作函数:
- `CONCAT(str1,str2,...)` 将多个字符串连接成一个字符串
- `UPPER(str)` 把给定的字符串转为大写形式
- `LOWER(str)` 把给定的字符串转为小写形式
```sql
SELECT CONCAT('hello', 'world'), UPPER('hive'), LOWER('HIVE');
```
#### 聚合函数
为了方便汇总统计数据,Hive 实现了几种重要的聚合功能:
- `SUM(col)` 计算列 col 所有记录之和
- `COUNT(*)` 统计表中总行数;`COUNT(DISTINCT col)` 只统计不同值的数量
- `AVG(col)` 平均值计算
```sql
SELECT SUM(salary), COUNT(*), AVG(age) FROM employees;
```
#### 日期时间函数
对于涉及时间和日期的操作,Hive 提供了一些实用工具来简化这类任务:
- `FROM_UNIXTIME(unixtime[,format])` Unix 时间戳转换为人可读的时间格式
- `UNIX_TIMESTAMP([date][,pattern])` 获取当前Unix时间戳或将特定日期转化为Unix时间戳
```sql
SELECT FROM_UNIXTIME(UNIX_TIMESTAMP(), '%Y-%m-%d %H:%i:%s') AS now_time;
```
#### 窗口函数
除了上述标准函数外,Hive 还引入了窗口函数的概念,允许执行更加灵活高效的查询逻辑。通过定义不同的窗口框架,可以在不改变原始数据集的情况下实现复杂的关系型计算。
- 使用 `ROW_NUMBER()` 函数配合 `OVER(PARTITION BY ... ORDER BY ...)`, 对分区内每条记录分配唯一编号[^3]
```sql
WITH ranked_activities AS (
SELECT *, ROW_NUMBER() OVER (PARTITION BY id, activity, cust_group ORDER BY expired_at DESC) as rn
FROM tb_activity_full
)
SELECT * FROM ranked_activities WHERE rn = 1;
```
阅读全文
相关推荐
















