Hive【Hive（四）函数-单行函数】

函数

函数简介

方便完成我们一些复杂的操作，就好像我们 Spark 中的 UDF 函数，避免用户反复写逻辑。

Hive  提供了大量的内置函数，主要可以分为以下几类：

  • 单行函数
  • 聚合函数
  • 炸裂函数
  • 窗口函数

下面的命令可以查看内置函数的相关信息：

1）查看系统自带的函数

show functions;

2）显示自带的函数的用法

查看函数 upper 的用法（显示函数参数）：

desc function upper;

3）详细显示自带的函数的用法

查看函数 upper 的详细用法：

desc function extended upper;

1、单行函数

特点：输入一行，输出一行（或多行）。

按照功能可以分为：

  • 日期函数
  • 字符串函数
  • 集合函数
  • 数学函数
  • 流程控制函数

1.1、算数运算函数

处理常用的 +、-、*、/ 还有 %、&、^、~、| 等

查询出员工薪资后全部 +100 显示：

select sal+1 from emp;

1.2、数值函数

1）round：四舍五入

默认不保留小数部分，直接四舍五入为整数。

select round(3.5);  -- 输出4

可以设置第二个参数（控制小数部分的长度）：

select round(3.1415,2)  --输出3.14
2）ceil：向上取整
select ceil(3.11);  -- 输出4
3）floor：向下取整
select floor(3.6);    --输出3

1.3、字符串函数

1）substring（str，beg[，len]）：截取字符串

解释：从第 beg 个下标对 str 进行截取，共截取 len 长度的字符串。

注意: 下标是从 1 开始的，负数代表取后 beg 位（-4代表取后4位）。

select substring("hello",1);    --返回helloselect substring("hello",1,2);  --返回heselect substring("hello",-4);    --返回elloselect substring("hello",-4,2);    --返回el
2）replace（str1,str2,str3）：替换

解释：将字符串 str1 中的子字符串 str2 用 str3 替换。

select replace("hello sxau",'sxau','tylg'); --返回 hello tylg
3）regexp_replace（str1,regex,str2）：正则替换

解释：将字符串 str1 中满足正则表达式 regex 的部分用 str2 替换掉。

select regexp_replace("身份证号:141125...","\\d",'*');  --返回 身份证号:******...

注意：这里的正则表达式语法是我们 Java 中的语法，比正常的正则表达式多一个斜杠 \；

4）regexp：正则匹配

解释：满足正则表达式返回 true 否则返回 false。

select '141125' regexp '\\d+';  --返回true
5）repeat（str，count）：重复字符串

将字符串 str 重复 count 次。

select repeat('good ',3);    --返回 good good good
6）split（str，regex）：字符串切割

解释：根据正则表达式 regex 将字符串切割开来。

注意：这里返回的是一个数组。

select split("name sex id sal",' '); --返回 ["name","sex","id","sal"]
7）nvl（a，b）：替换 null 值

解释：如果 a 不是null，则返回a，否则返回 b。

用法：通常用于判断字段是否为空。

select nvl(null,1);    --返回1
8）concat（str1，str2，...）：拼接字符串
select concat('tom','jerry','school');  --返回 tomjerryschool
9）concat_ws：以指定的分隔符拼接字符串
select concat_ws('.','192','168','88','134') --返回 192.168.88.134
10）get_json_object（json_string，path）：解析json字符串

JSON 的相关知识可以查看菜鸟教程。

解释：解析 json 字符串 json_string，并返回 path 指定的内容。如果输入的 json 字符串无效，那么返回 null。

-- 返回 lyh
select get_json_object('{"name": "lyh",	"friends": ["my","zht"],"students": {"drj": 48,"lyf": 30},"address": {"street": "chang an jie","city":	"beijing","postal_code": 10010}}','$.name');

注意：

  1. 如果是 json 数组，可以通过 '$.[0].name' 的方式获取到下标为 0 的json对象的 name 属性值。
  2. 注意如果 json 字符串内用的是双引号，那么我们的函数参数最好用单引号。

1.4、日期函数

我们的日期时间基本格式为：年-月-日 时:分:秒 

1）unix_timestamp（[date_str，format]）：返回当前或指定时间的时间戳

解释：将时间字符串 date_str 根据 format 格式解析为时间戳。

注意：一定要注意字符串 date_str 中的间隔符必须要和 format 中一一对应。

select unix_timestamp();    --当前时间的时间戳  1696390814select unix_timestamp('2023/10/04 11-41-08','yyyy/MM/dd HH-mm-ss');    -- 1696419668
2）from_unixtime（timestamp）：将时间戳转为时间

注意：

  1. 这里的参数不是字符串，而是一个数值。
  2. from_unixtime() 只能精确到秒级别。
  3. from_utc_time() 可以精确到毫秒级别，但相应的如果参数是 unix_timestamp 需要*1000 转为毫秒数。
select from_unixtime(1696419668);    --输出 2023-10-04 11:41:08select from_utc_timestamp(cast(1696419668 as bigint)*1000,'GMT+8');
3）current_date（）：当前日期

注意：括号可以省略。

select current_date;    --返回 2023-10-04
4）current_timestamp（）：当前日期的时间，并精确到毫秒
select current_timestamp();     --返回 2023-10-04 11:49:51.696000000
5）month（str）：获取日期中的月
select month(current_date());    --返回 10
6）day（str）：获取日期的日
select day(current_date());    --返回 4
7）hour（str）：获取日期的时
select hour('2023-10-04 11:59:10');    --返回 11
8）datediff（enddate，startdate）：两个日期相差的天数
select datediff('2023-10-4','2023-10-1');    --返回 3
9）date_add（startdate，days）：日期加天数

注意：有 add 就有 sub，一个加，一个减。

select date_add('2023-10-1',365);    --返回 2024-9-30select date_sub('2023-10-1',365);    --返回 2022-10-1
10）date_format（date-str，format）：将日期字符串转为指定格式的字符串
select date_format('2023-10-4 12:00:05','yyyy年MM月dd日-HH时mm分:ss秒'); --返回2023年10月04日-12时00分:05秒

1.5、流程控制函数

1）case when：条件判断函数
select stu_id,course_id,score,casewhen score>=90 then 'A'when score>=80 then 'B'when score>=70 then 'C'when score>=60 then 'D'else '不及格'end as grade
from score_info;

如果是等值查询（直接 case 后面跟字段名，when 条件处直接写值即可）：

select stu_id,course_id,score,case scorewhen 90 then 'A'when 80 then 'B'when 70 then 'C'when 60 then 'D'end as grade
from score_info;
2）if：条件判断，类似于 Java 的三元运算符
select stu_id,course_id,if(score>60,'及格','不及格') `grade`
from score_info;

1.6、集合函数

集合函数用来处理复杂的数据类型，比如 array、map 和 struct。

1）size ：集合中元素的个数
select size(array(1,2,3));    --3
2）map（k1，v1，k2，v2）：创建 map 集合
select map('hadoop',1,'spark',1);    --{"hadoop":1,"spark":1}
3）map_keys（map）：返回 map 中的 key
select map_keys(map('hadoop',1,'spark',1));    --["hadoop","spark"]
4）map_values（map）：返回 map 中的 value
select map_values(map('hadoop',1,'spark',1));    --[1,1]
5）array：声明 array 集合
select array(1,2,3);    --[1,2,3]
6）array_contains（arr，ele）：判断 arr 中是否包含元素 ele
select array_contains(array(1,2,3),3);    --true
7）sort_array（arr）：将 arr 中的元素排序
select sort_array(array(5,3,4,1));    --[1,3,4,5]
8）struct：声明 struct
select struct('name','age','sex');    --{"col1":"name","col2":"age","col3":"sex"}
9）named_struct（）：声明 struct 的属性和值
select named_struct('name',"tom",'age',"18",'sex',"男");    --{"name":"tom","age":"18","sex":"男"}

 案例演示

数据准备

create  table  employee(name string,  --姓名sex  string,  --性别birthday string, --出生年月hire_date string, --入职日期job string,   --岗位salary double, --薪资bonus double,  --奖金friends array<string>, --朋友children map<string,int> --孩子
);
insert into employeevalues('张无忌','男','1980/02/12','2022/08/09','销售',3000,12000,array('阿朱','小昭'),map('张小无',8,'张小忌',9)),('赵敏','女','1982/05/18','2022/09/10','行政',9000,2000,array('阿三','阿四'),map('赵小敏',8)),('宋青书','男','1981/03/15','2022/04/09','研发',18000,1000,array('王五','赵六'),map('宋小青',7,'宋小书',5)),('周芷若','女','1981/03/17','2022/04/10','研发',18000,1000,array('王五','赵六'),map('宋小青',7,'宋小书',5)),('郭靖','男','1985/03/11','2022/07/19','销售',2000,13000,array('南帝','北丐'),map('郭芙',5,'郭襄',4)),('黄蓉','女','1982/12/13','2022/06/11','行政',12000,null,array('东邪','西毒'),map('郭芙',5,'郭襄',4)),('杨过','男','1988/01/30','2022/08/13','前台',5000,null,array('郭靖','黄蓉'),map('杨小过',2)),('小龙女','女','1985/02/12','2022/09/24','前台',6000,null,array('张三','李四'),map('杨小过',2));

需求

1）统计每个月的入职人数
select month(replace(hire_date,'/','-')) as month,count(*) as cn
from employee
group by
month(replace(hire_date,'/','-'));
2）查询每个人的年龄（年+月）
select name,concat(if(month>=0,year,year-1),'年',if(month>=0,month,12+month),'月') age
from(
select name,year(current_date())-year(t1.birthday) year,month(current_date())-month(t1.birthday) month
from (select name,replace(birthday,'/','-') birthdayfrom employee
)t1)t2;
3）按照薪资进行倒序，如果奖金为 null 置为 0
select name,salary+nvl(bonus,0) 
from employee
order by salary;
4）查询每个人有多少个朋友
select name,size(friends) `朋友` from employee;
5）查询每个人孩子的姓名
select name,map_keys(children) from employee;
6）查询每个岗位男女各多少人
select job,sum(if(sex='男',1,0)) male,sum(if(sex='女',1,0)) female
from employee
group by job;

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/95316.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

Html+Css+Js计算时间差，返回相差的天/时/分/秒(从未来的一个日期时间到当前日期时间的差)。

Html+Css+Js计算时间差，返回相差的天/时/分/秒(从未来的一个日期时间到当前日期时间的差)。

Html部分 <!DOCTYPE html> <html><head><meta charset"utf-8" /><title></title><link rel"stylesheet" type"text/css" href"css/index.css" /><script src"js/index.js" t…
阅读更多...
仿牛客论坛项目 笔记

仿牛客论坛项目 笔记

文章目录 环境配置bean是什么最终成品功能数据库与缓存一致性整个web系统后端的结构spring mvc相关controller常见的代码写法mybatis相关常识测试、调试相关计网相关component相关注解spring全家桶族谱spring衍生框架 run之后发生了什么什么是spring&#xff0c;spring和bean的…
阅读更多...
【计算机组成原理】考研真题攻克与重点知识点剖析 - 第 2 篇：数据的表示和运算

【计算机组成原理】考研真题攻克与重点知识点剖析 - 第 2 篇：数据的表示和运算

前言 本文基础知识部分来自于b站&#xff1a;分享笔记的好人儿的思维导图与王道考研课程&#xff0c;感谢大佬的开源精神&#xff0c;习题来自老师划的重点以及考研真题。此前我尝试了完全使用Python或是结合大语言模型对考研真题进行数据清洗与可视化分析&#xff0c;本人技术…
阅读更多...
docker 安装kafka

docker 安装kafka

运行容器 zookeeper: [rootk8s-master ~]# docker run -d --restartalways --log-driver json-file --log-opt max-size100m --log-opt max-file2 --name zookeeper -p 2181:2181 -v /etc/localtime:/etc/localtime zookeeper c603f292813cfd6e2b16fff88a9767cc86fc9bba34d82…
阅读更多...
开源协作开发者内容平台Vrite

开源协作开发者内容平台Vrite

什么是 Vrite &#xff1f; Vrite 是一个开源协作空间&#xff0c;用于创建、管理和部署产品文档、技术博客和知识库。它旨在提供高质量、集成的用户和开发人员体验。 Vrite 具有以下功能&#xff1a; 内置管理仪表板&#xff0c;用于使用看板或列表视图管理内容生产和交付&am…
阅读更多...
SpringCloud（二）Docker、Spring AMQP、ElasticSearch

SpringCloud（二）Docker、Spring AMQP、ElasticSearch

文章目录 DockerDocker与虚拟机Docker架构镜像、容器、镜像托管平台Docker架构Docker实践 Spring AMQP简单使用案例工作队列- WorkQueue发布订阅服务FanoutExchangeDirectExchangeTopicExchange 消息转换器 ElasticSearch倒排索引IK分词器IK分词拓展与停用字典 操作索引库mappi…
阅读更多...
Dubbo 融合 Nacos 成为注册中心

Dubbo 融合 Nacos 成为注册中心

Nacos 作为 Dubbo 生态系统中重要的注册中心实现&#xff0c;本文将会介绍如何进行 Dubbo 对接 Nacos 注册中心的工作。 预备工作 请确保后台已经启动 Nacos 服务 快速上手 Dubbo 融合 Nacos 成为注册中心的操作步骤非常简单&#xff0c;大致步骤可分为“增加 Maven 依赖”…
阅读更多...
与值域有关的问题（非权值线段树）——运用分块：1004T1

与值域有关的问题（非权值线段树）——运用分块：1004T1

区间小于等于某值区间加 显然同时涉及区间和值域&#xff0c;不能用log级ds来做&#xff0c;常见套路就是上分块 这题是个复合题&#xff0c;后面就是个组合数 #include<bits/stdc.h> using namespace std; #define int long long inline int read(){int x0,f1;char c…
阅读更多...
创建vue3工程

创建vue3工程

一、新建工程目录E:\vue\projectCode\npm-demo用Visual Studio Code 打开目录 二、点击新建文件夹按钮&#xff0c;新建vue3-01-core文件夹 三、右键vue3-01-core文件夹点击在集成终端中打开 四、初始化项目&#xff0c;输入npm init 一直敲回车直到创建成功如下图 npm init 五…
阅读更多...
国庆加速度！新增功能点锁定功能，敏捷开发新增估算功能，助力项目快速突破！

国庆加速度！新增功能点锁定功能，敏捷开发新增估算功能，助力项目快速突破！

大家好&#xff0c;CoCode开发云旗下Co-Project V3.6智能项目管理平台正式发布&#xff0c;平台新增功能点锁定功能、敏捷开发模式新增估算板块和两种估算方式。 功能点锁定功能进一步提高了项目估算的灵活性和准确性&#xff0c;有利于提高项目估算效率&#xff1b;而敏捷开发…
阅读更多...
JAVA面经整理(8)

JAVA面经整理(8)

一)为什么要有区&#xff0c;段&#xff0c;页&#xff1f; 1)页是内存和磁盘之间交互的基本单位内存中的值修改之后刷到磁盘的时候还是以页为单位的索引结构给程序员提供了高效的索引实现方式&#xff0c;不过索引信息以及数据记录都是记录在文件上面的&#xff0c;确切来说是…
阅读更多...
六、互联网技术——数据存储

六、互联网技术——数据存储

文章目录 一、存储系统层次结构二、按照重要性分类三、磁盘阵列RAID三、RAID基础四、磁盘阵列分级五、数据备份与恢复六、容灾与灾难恢复 一、存储系统层次结构 常见的三层存储体系结构如下图所示&#xff0c;分为高速缓冲存储器、主存储器和外存储器。 二、按照重要性分类 …
阅读更多...
Android自定义Drawable---灵活多变的矩形背景

Android自定义Drawable---灵活多变的矩形背景

Android自定义Drawable—灵活多变的矩形背景 在安卓开发中&#xff0c;我们通常需要为不同的按钮设置不同的背景以实现不同的效果&#xff0c;有时还需要这些按钮根据实际情况进行变化。如果采用编写resource中xml文件的形式&#xff0c;就需要重复定义许多只有微小变动的资源…
阅读更多...
CSDN Q: “这段代码算是在STC89C52RC51单片机上完成PWM呼吸灯了吗?“

CSDN Q: “这段代码算是在STC89C52RC51单片机上完成PWM呼吸灯了吗?“

这是 CSDN上的一个问题 这段代码算是在STC89C52RC51单片机上完成PWM呼吸灯了吗&#xff0c;还是说得用上定时器和中断函数#include <regx52.h> 我个人认为: 效果上来说, 是的! 码以 以Time / 100-Time 调 Duty, 而 for i loop成 Period, 加上延时, 实现了 PWM周期, 虽然…
阅读更多...
【LeetCode热题100】--34.在排序数组中查找元素的第一个和最后一个位置

【LeetCode热题100】--34.在排序数组中查找元素的第一个和最后一个位置

34.在排序数组中查找元素的第一个和最后一个位置 二分查找中&#xff0c;寻找 leftIdx 即为在数组中寻找第一个大于等于 target 的下标&#xff0c;寻找 rightIdx 即为在数组中寻找第一个大于 target 的下标&#xff0c;然后将下标减一。进行两次查找 class Solution {public …
阅读更多...
43 验证二叉搜索树

43 验证二叉搜索树

验证二叉搜索树 理解题意&#xff1a;验证搜索二叉树&#xff1a;中序遍历是升序题解1 递归&#xff08;学习学习&#xff01;&#xff09;题解2 中序遍历&#xff08;保持升序&#xff09; 给你一个二叉树的根节点 root &#xff0c;判断其是否是一个 有效的二叉搜索树。 有…
阅读更多...
Flutter项目安装到Android手机一直显示在assembledebug

Flutter项目安装到Android手机一直显示在assembledebug

问题 Flutter项目安装到Android手机一直显示在assembledebug 原因 网络不好&#xff0c;gradle依赖下载不下来 解决方案 修改如下的文件 gradle-wrapper.properties 使用腾讯提供的gradle镜像下载 distributionUrlhttps://mirrors.cloud.tencent.com/gradle/gradle-7.5…
阅读更多...
mac openssl 版本到底怎么回事 已解决

mac openssl 版本到底怎么回事 已解决

在mac 安装node多版本的时候&#xff0c;有可能把原有的 openssl1.1 版本 直接要再一次升级了&#xff0c;无奈的 php环境 编译器是 openssl 1.1 还是 3.0 &#xff0c;今天来个底朝天的找问题。 brew search openssl 有安装 三个版本。 但是错误提示 是第二个版本。 brew …
阅读更多...
十月四日作业

十月四日作业

1、服务器 头文件&#xff1a; #ifndef WIDGET_H #define WIDGET_H#include <QWidget> #include <QTcpServer> //服务器头文件 #include <QTcpSocket> //客户端头文件 #include <QList> //链表容器 #include <…
阅读更多...
git 提交代码，解决分支冲突，合并分支

git 提交代码，解决分支冲突，合并分支

克隆代码 git clone 仓库地址 克隆指定分支 git clone -b 分支名称 仓库地址 上传到分支上 1.克隆代码&#xff1a;git clone 仓库地址 注意&#xff1a;克隆仓库&#xff0c;会自动连接远程仓库的 2.修改代码完毕 3.git init 4.创建分支&#xff1a;git branch 分支名称 5…
阅读更多...
最新文章

Copyright @ 2022~2023