Hive分区、分桶、类型、函数、运算符指令详解

刺骨的言语ヽ痛彻心扉 2022-02-27 15:30 435阅读 0赞

## 内部表和外部表 ##

#### 一、内部表的概念 ####

先在hive里建一张表，然后向这个表插入数据（用insert可以插入数据，也可以通过加载外部文件方式来插入数据），这样的表称之为hive的内部表

#### 二、外部表的概念 ####

1.  HDFS里已经有数据了，然后，通过hive创建一张表来管理这个文件数据。则这样表称之为外部表
2.  注意，hive外部表管理的是HDFS里的某一个目录下的文件数据

#### 三、外部表创建命令： ####

进入hive，执行：create external table stu (id int,name string) row format delimited fields terminated by ’ ’ location ‘/目录路径’

#### 四、内部表和外部标的区别 ####

1.  对于内部表，在删除该表的时候，HDFS对应的目录节点会被删除
2.  对于外部表，在删除该表的时候，HDFS对应的目录节点不会删除

## 基础命令详解 ##

<table> 
 <thead> 
  <tr> 
   <th align="left">命令</th> 
   <th align="left">作用</th> 
   <th align="left">额外说明</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td align="left">show databases;</td> 
   <td align="left">查看都有哪些数据库</td> 
   <td align="left"></td> 
  </tr> 
  <tr> 
   <td align="left">create database park;</td> 
   <td align="left">创建park数据库</td> 
   <td align="left">创建的数据库，实际是在Hadoop的HDFS文件系统里创建一个目录节点，统一存在： /user/hive/warehouse 目录下</td> 
  </tr> 
  <tr> 
   <td align="left">use park;</td> 
   <td align="left">进入park数据库</td> 
   <td align="left"></td> 
  </tr> 
  <tr> 
   <td align="left">show tables;</td> 
   <td align="left">查看当前数据库下所有表</td> 
   <td align="left"></td> 
  </tr> 
  <tr> 
   <td align="left">create table stu (id int,name string);</td> 
   <td align="left">创建stu表，以及相关的两个字段</td> 
   <td align="left">1. hive里，表示字符串用的是string，不用char和varchar <br>2. 所创建的表，也是HDFS里的一个目录节点</td> 
  </tr> 
  <tr> 
   <td align="left">insert into stu values(1,‘zhang’)</td> 
   <td align="left">向stu表插入数据</td> 
   <td align="left">1. HDFS不支持数据的修改和删除，因此已经插入的数据不能够再进行任何的改动 <br>2. 在Hadoop2.0版本后支持了数据追加。实际上，insert into 语句执行的是追加操作 <br>3. hive支持查询，行级别的插入。不支持行级别的删除和修改 <br>4. hive的操作实际是执行一个job任务，调用的是Hadoop的MR <br>5. 插入完数据之后，发现HDFS stu目录节点下多了一个文件，文件里存了插入的数据，因此，hive存储的数据，是通过HDFS的文件来存储的。</td> 
  </tr> 
  <tr> 
   <td align="left">select * from stu</td> 
   <td align="left">查看表数据</td> 
   <td align="left">也可以根据字段来查询，比如select id from stu</td> 
  </tr> 
  <tr> 
   <td align="left">drop table stu</td> 
   <td align="left">删除表</td> 
   <td align="left"></td> 
  </tr> 
  <tr> 
   <td align="left">load data local inpath ‘/home/software/1.txt’ into table stu;</td> 
   <td align="left">通过加载文件数据到指定的表里</td> 
   <td align="left">1. 在执行完这个指令之后，发现hdfs stu目录下多了一个1.txt文件。由此可见，hive的工作原理实际上就是在管理hdfs上的文件，把文件里数据抽象成二维表结构，然后提供hql语句供程序员查询文件数据 <br>2. 可以做这样的实验：不通过load 指令，而通过插件向stu目录下再上传一个文件，看下hive是否能将数据管理到stu表里。</td> 
  </tr> 
  <tr> 
   <td align="left">create table stu1(id int,name string) row format delimited fields terminated by ’ ';</td> 
   <td align="left">创建stu1表，并指定分割符 空格。</td> 
   <td align="left"></td> 
  </tr> 
  <tr> 
   <td align="left">desc stu</td> 
   <td align="left">查看 stu表结构</td> 
   <td align="left"></td> 
  </tr> 
  <tr> 
   <td align="left">create table stu2 like stu</td> 
   <td align="left">创建一张stu2表，表结构和stu表结构相同</td> 
   <td align="left">like只复制表结构，不复制数据</td> 
  </tr> 
  <tr> 
   <td align="left">insert overwrite table stu2 select * from stu</td> 
   <td align="left">把stu表数据插入到stu2表中</td> 
   <td align="left"></td> 
  </tr> 
  <tr> 
   <td align="left">insert overwrite local directory ‘/home/stu’ row format delimited fields terminated by ’ ’ select * from stu;</td> 
   <td align="left">将stu表中查询的数据写到本地的/home/stu目录下</td> 
   <td align="left"></td> 
  </tr> 
  <tr> 
   <td align="left">insert overwrite directory ‘/stu’ row format delimited fields terminated by ’ ’ select * from stu;</td> 
   <td align="left">将stu表中查询的数据写到HDFS的stu目录下</td> 
   <td align="left"></td> 
  </tr> 
  <tr> 
   <td align="left">from stu insert overwrite table stu1 select * insert overwrite table stu2 select *;</td> 
   <td align="left">将stu表中查询的数据写到stu1以及stu2两张表中</td> 
   <td align="left"></td> 
  </tr> 
  <tr> 
   <td align="left">alter table stu rename to stu2</td> 
   <td align="left">为表stu重命名为stu2</td> 
   <td align="left"></td> 
  </tr> 
  <tr> 
   <td align="left"></td> 
   <td align="left"></td> 
   <td align="left"></td> 
  </tr> 
  <tr> 
   <td align="left">alter table stu add columns (age int);</td> 
   <td align="left">为表stu增加一个列字段age，类型为int</td> 
   <td align="left"></td> 
  </tr> 
  <tr> 
   <td align="left">exit</td> 
   <td align="left">退出hive</td> 
   <td align="left"></td> 
  </tr> 
 </tbody> 
</table>

## 分区表指令 ##

#### 一、分区表概述 ####

1.  分区表可以通过添加指定的字段来提高Hive的查询效率
2.  在数据量较大的情况下，往往会添加分区表来避免全表查询

#### 二、分区表指令 ####

<table> 
 <thead> 
  <tr> 
   <th align="left">指令</th> 
   <th align="left">作用</th> 
   <th align="left">额外说明</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td align="left">create table book (id int, name string) partitioned by (category string) row format delimited fields terminated by ‘\t’;</td> 
   <td align="left">创建book表，以category作为分区</td> 
   <td align="left">在创建分区表时，partitioned字段可以不在字段列表中。生成的表中自动就会具有该字段。</td> 
  </tr> 
  <tr> 
   <td align="left">load data local inpath ‘/home/cn.txt’ overwrite into table book partition (category=‘cn’);</td> 
   <td align="left">将本地文件cn.txt添加到book表中，分区字段为cn</td> 
   <td align="left">在HDFS下生成category=cn目录</td> 
  </tr> 
  <tr> 
   <td align="left">select * from book where category=‘cn’;</td> 
   <td align="left">查看分区为cn的数据</td> 
   <td align="left"></td> 
  </tr> 
  <tr> 
   <td align="left">ALTER TABLE book add PARTITION (category = ‘jp’) location ‘/user/hive/warehouse/park.db/book/category=jp’;</td> 
   <td align="left">将指定的目录添加为分区字段</td> 
   <td align="left"></td> 
  </tr> 
  <tr> 
   <td align="left">show partitions iteblog;</td> 
   <td align="left">查看分区</td> 
   <td align="left"></td> 
  </tr> 
  <tr> 
   <td align="left">msck repair table book;</td> 
   <td align="left">修复分区</td> 
   <td align="left"></td> 
  </tr> 
  <tr> 
   <td align="left">alter table book drop partition(category=‘cn’);</td> 
   <td align="left">删除分区</td> 
   <td align="left"></td> 
  </tr> 
  <tr> 
   <td align="left">alter table book partition(category=‘french’) rename to partition (category=‘hh’);</td> 
   <td align="left">修改分区的名字</td> 
   <td align="left"></td> 
  </tr> 
 </tbody> 
</table>

## 分桶表指令 ##

#### 一、概述 ####

1.  分桶表是一种更细粒度的数据分配方式
2.  一个表既可以分区也可以分桶
3.  分桶的主要作用是实现数据的抽样，方便进行数据测试
4.  分桶表通过hash分桶算法，将数据分放在不同的桶(hdfs中的文件)中，方便后续获取
5.  分桶表机制默认是不开启的，需要手动开启：set hive.enforce.bucketing=true;
6.  分桶表不允许以外部文件方式导入数据，只能从另外一张表数据导入

#### 二、分桶表语法 ####

<table> 
 <thead> 
  <tr> 
   <th align="left">指令</th> 
   <th align="left">作用</th> 
   <th align="left">额外说明</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td align="left">create table teacher(name string) clustered by (name) into 3 buckets row format delimited fields terminated by ’ ';</td> 
   <td align="left">创建teacher表，以name作为分桶机制，分为3个桶</td> 
   <td align="left"></td> 
  </tr> 
  <tr> 
   <td align="left">insert overwrite table teacher select * from tmp;</td> 
   <td align="left">将tmp表中的数据添加到teacher表中</td> 
   <td align="left">实际上是产生了3个文件用于存储不分桶的数据</td> 
  </tr> 
  <tr> 
   <td align="left">select * from teacher tablesample(bucket 1 out of 3 on name);</td> 
   <td align="left">进行抽样</td> 
   <td align="left">抽样格式为：bucket x out of y on XXX<br>1. x表示抽样的起始桶，例如bucket 1 out of 3表示从第1 个桶开始抽取数据<br>2. y决定抽样的比例，要求必须是桶数的因子或者整数倍<br>a. 如果桶数为6，y为2，则表示抽取6/2=3个桶中的数据<br>b. 如果桶数为6，y为3，则表示抽取6/3=2个桶中的数据<br> c. 如果桶数为6，y为12，则表示抽取6/12=0.5个桶中的数据<br>3. 如果桶数为6，抽样为bucket 1 out of 3 on id表示从第1个桶开始抽样，抽取2个桶的数据，所以抽取的样本为1和4桶中的数据</td> 
  </tr> 
 </tbody> 
</table>

## 数据类型 ##

#### 一、基本类型 ####

<table> 
 <thead> 
  <tr> 
   <th>Hive中的类型</th> 
   <th>Java中的类型</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>tinyint</td> 
   <td>byte</td> 
  </tr> 
  <tr> 
   <td>smallint</td> 
   <td>short</td> 
  </tr> 
  <tr> 
   <td>int</td> 
   <td>int</td> 
  </tr> 
  <tr> 
   <td>bigint</td> 
   <td>long</td> 
  </tr> 
  <tr> 
   <td>boolean</td> 
   <td>boolean</td> 
  </tr> 
  <tr> 
   <td>float</td> 
   <td>float</td> 
  </tr> 
  <tr> 
   <td>double</td> 
   <td>double</td> 
  </tr> 
  <tr> 
   <td>string</td> 
   <td>String</td> 
  </tr> 
  <tr> 
   <td>timestamp</td> 
   <td>TimeStamp</td> 
  </tr> 
  <tr> 
   <td>binary</td> 
   <td>byte[]</td> 
  </tr> 
 </tbody> 
</table>

#### 二、复杂类型 ####

##### 数组类型 array #####

**案例一**  
原始数据：  
100,200,300  
200,300,500  
建表语句：

create external table ex(vals array<int>) row format delimited fields terminated by '\t' collection items terminated by ',' location '/ex';

查询每行数组的个数，查询语句：

select  size(vals) from ex;

注：hive 内置函数不具备查询某个具体行的数组元素。需要自定义函数来实现，但这样的需求在实际开发里很少，所以不需要在意。  
**案例二**  
原始数据：  
100,200,300 tom,jary  
200,300,500 rose,jack  
建表语句：

create external table ex1(info1 array<int>,info2 array<string>) row format delimited fields terminated by '\t' collection items terminated by ',' location '/ex';

结果：  
![在这里插入图片描述][2019032802400646.png]

##### map类型 #####

**案例一**  
原始数据：  
tom,23  
rose,25  
jary,28  
建表语句：

create external table m1 (vals map<string,int>) row format delimited fields terminated by '\t' map keys terminated by ',' location '/map';

查询语句：

select vals['tom'] from m1;

![在这里插入图片描述][20190328024000724.png]  
**案列二**  
原始数据：  
tom 192.168.234.21  
rose 192.168.234.21  
tom 192.168.234.22  
jary 192.168.234.21  
tom 192.168.234.24  
tom 192.168.234.21  
rose 192.168.234.21  
tom 192.168.234.22  
jary 192.168.234.21  
tom 192.168.234.22  
tom 192.168.234.23  
建表语句 ：

create external table ex (vals map<string,string>) row format delimited fields terminated by '\t' map keys terminated by ' ' location '/ex';

注意：map类型，列的分割符必须是\\t  
查询语句

select vals['tom'] from ex where vals['tom'] is not null;

如果想做去重工作，可以调用distinct内置函数

select distinct(ip) from (select vals['tom'] ip from ex where vals['tom'] is not null)ex1;
    或者
    select distinct(vals['tom']) from m2 where vals['tom'] is not null;

![在这里插入图片描述][20190328023945949.png]

##### struct 类型 #####

原始数据：  
tom 23  
rose 22  
jary 26  
建表语句：

create external table ex (vals struct<name:string,age:int>)row format delimited collection items terminated by ' '  location '/ex';

查询语句：

select vals.age from ex where vals.name='tom';

## 内置函数 ##

Hive实现了标准的sql，但在这之外，为了提升hive处理数据的能力，还额外提供了很多内置的函数，这些内置函数非常丰富，且可以直接使用，虽然不属于sql原生的语法，但大大的增强了hive处理数据的能力，是hive功能的重要组成部分。

### 运算符 ###

#### 一、关系运算符 ####

<table> 
 <thead> 
  <tr> 
   <th align="left">运算符</th> 
   <th align="left">类型</th> 
   <th align="left">说明</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td align="left">A = B</td> 
   <td align="left">所有原始类型</td> 
   <td align="left">如果A与B相等，返回true，否则返回false</td> 
  </tr> 
  <tr> 
   <td align="left">A == B</td> 
   <td align="left">无</td> 
   <td align="left">失败，因为无效的语法。 SQL使用”=”，不使用”==”。</td> 
  </tr> 
  <tr> 
   <td align="left">A &lt;&gt; B</td> 
   <td align="left">所有原始类型</td> 
   <td align="left">如果A不等于B返回TRUE,否则返回FALSE。如果A或B值为”NULL”，结果返回”NULL”。</td> 
  </tr> 
  <tr> 
   <td align="left">A &lt; B</td> 
   <td align="left">所有原始类型</td> 
   <td align="left">如果A小于B返回TRUE,否则返回FALSE。如果A或B值为”NULL”，结果返回”NULL”。</td> 
  </tr> 
  <tr> 
   <td align="left">A &lt;= B</td> 
   <td align="left">所有原始类型</td> 
   <td align="left">如果A小于等于B返回TRUE,否则返回FALSE。如果A或B值为”NULL”，结果返回”NULL”。</td> 
  </tr> 
  <tr> 
   <td align="left">A &gt; B</td> 
   <td align="left">所有原始类型</td> 
   <td align="left">如果A大于B返回TRUE,否则返回FALSE。如果A或B值为”NULL”，结果返回”NULL”。</td> 
  </tr> 
  <tr> 
   <td align="left">A &gt;= B</td> 
   <td align="left">所有原始类型</td> 
   <td align="left">如果A大于等于B返回TRUE,否则返回FALSE。如果A或B值为”NULL”，结果返回”NULL”。</td> 
  </tr> 
  <tr> 
   <td align="left">A IS NULL</td> 
   <td align="left">所有类型</td> 
   <td align="left">如果A值为”NULL”，返回TRUE,否则返回FALSE</td> 
  </tr> 
  <tr> 
   <td align="left">A IS NOT NULL</td> 
   <td align="left">所有类型</td> 
   <td align="left">如果A值不为”NULL”，返回TRUE,否则返回FALSE</td> 
  </tr> 
  <tr> 
   <td align="left">A LIKE B</td> 
   <td align="left">字符串</td> 
   <td align="left">如果A或B值为”NULL”，结果返回”NULL”。字符串A与B通过sql进行匹配，如果相符返回TRUE，不符返回FALSE。B字符串中 的”<em>”代表任一字符，”%”则代表多个任意字符。例如： (‘foobar’ like ‘foo’)返回FALSE，（ ‘foobar’ like ‘foo</em> _ _’或者 ‘foobar’ like ‘foo%’)则返回TURE</td> 
  </tr> 
  <tr> 
   <td align="left">A RLIKE B</td> 
   <td align="left">字符串</td> 
   <td align="left">如果A或B值为”NULL”，结果返回”NULL”。字符串A与B通过java进行匹配，如果相符返回TRUE，不符返回FALSE。例如：（ ‘foobar’ rlike ‘foo’）返回FALSE，（’foobar’ rlike ‘^f.*r$’ ）返回TRUE。</td> 
  </tr> 
  <tr> 
   <td align="left">A REGEXP B</td> 
   <td align="left">字符串</td> 
   <td align="left">与RLIKE相同。</td> 
  </tr> 
 </tbody> 
</table>

#### 二、算数运算符 ####

<table> 
 <thead> 
  <tr> 
   <th align="left">运算符</th> 
   <th align="left">类型</th> 
   <th align="left">说明</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td align="left">A + B</td> 
   <td align="left">所有数字类型</td> 
   <td align="left">A和B相加。结果的与操作数值有共同类型。例如每一个整数是一个浮点数，浮点数包含整数。所以，一个浮点数和一个整数相加结果也是一个浮点数。</td> 
  </tr> 
  <tr> 
   <td align="left">A – B</td> 
   <td align="left">所有数字类型</td> 
   <td align="left">A和B相减。结果的与操作数值有共同类型。</td> 
  </tr> 
  <tr> 
   <td align="left">A * B</td> 
   <td align="left">所有数字类型</td> 
   <td align="left">A和B相乘，结果的与操作数值有共同类型。需要说明的是，如果乘法造成溢出，将选择更高的类型。</td> 
  </tr> 
  <tr> 
   <td align="left">A / B</td> 
   <td align="left">所有数字类型</td> 
   <td align="left">A和B相除，结果是一个double（双精度）类型的结果。</td> 
  </tr> 
  <tr> 
   <td align="left">A % B</td> 
   <td align="left">所有数字类型</td> 
   <td align="left">A除以B余数与操作数值有共同类型。</td> 
  </tr> 
  <tr> 
   <td align="left">A &amp; B</td> 
   <td align="left">所有数字类型</td> 
   <td align="left">运算符查看两个参数的二进制表示法的值，并执行按位”与”操作。两个表达式的一位均为1时，则结果的该位为 1。否则，结果的该位为 0。</td> 
  </tr> 
  <tr> 
   <td align="left">A</td> 
   <td align="left">B</td> 
   <td align="left">所有数字类型</td> 
  </tr> 
  <tr> 
   <td align="left">A ^ B</td> 
   <td align="left">所有数字类型</td> 
   <td align="left">运算符查看两个参数的二进制表示法的值，并执行按位”异或”操作。当且仅当只有一个表达式的某位上为 1 时，结果的该位才为 1。否则结果的该位为 0。</td> 
  </tr> 
  <tr> 
   <td align="left">~A</td> 
   <td align="left">所有数字类型</td> 
   <td align="left">对一个表达式执行按位”非”（取反）。</td> 
  </tr> 
  <tr> 
   <td align="left"></td> 
   <td align="left"></td> 
   <td align="left"></td> 
  </tr> 
 </tbody> 
</table>

#### 三、逻辑运算符 ####

<table> 
 <thead> 
  <tr> 
   <th align="left">运算符</th> 
   <th align="left">类型</th> 
   <th align="left">说明</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td align="left">A AND B</td> 
   <td align="left">布尔值</td> 
   <td align="left">A和B同时正确时,返回TRUE,否则FALSE。如果A或B值为NULL，返回NULL。</td> 
  </tr> 
  <tr> 
   <td align="left">A &amp;&amp; B</td> 
   <td align="left">布尔值</td> 
   <td align="left">与”A AND B”相同</td> 
  </tr> 
  <tr> 
   <td align="left">A OR B</td> 
   <td align="left">布尔值</td> 
   <td align="left">A或B正确,或两者同时正确返返回TRUE,否则FALSE。如果A和B值同时为NULL，返回NULL。</td> 
  </tr> 
  <tr> 
   <td align="left">A</td> 
   <td align="left">B</td> 
   <td align="left">布尔值</td> 
  </tr> 
  <tr> 
   <td align="left">NOT A</td> 
   <td align="left">布尔值</td> 
   <td align="left">如果A为NULL或错误的时候返回TURE，否则返回FALSE。</td> 
  </tr> 
  <tr> 
   <td align="left">! A</td> 
   <td align="left">布尔值</td> 
   <td align="left">与”NOT A”相同</td> 
  </tr> 
 </tbody> 
</table>

### 函数 ###

#### 一、数学函数 ####

<table> 
 <thead> 
  <tr> 
   <th align="left">返回类型</th> 
   <th align="left">函数</th> 
   <th align="left">说明</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td align="left">BIGINT</td> 
   <td align="left">round(double a)</td> 
   <td align="left">四舍五入</td> 
  </tr> 
  <tr> 
   <td align="left">DOUBLE</td> 
   <td align="left">round(double a, int d)</td> 
   <td align="left">小数部分d位之后数字四舍五入，例如round(21.263,2),返回21.26</td> 
  </tr> 
  <tr> 
   <td align="left">BIGINT</td> 
   <td align="left">floor(double a)</td> 
   <td align="left">对给定数据进行向下舍入最接近的整数。例如floor(21.2),返回21。</td> 
  </tr> 
  <tr> 
   <td align="left">BIGINT</td> 
   <td align="left">ceil(double a), ceiling(double a)</td> 
   <td align="left">将参数向上舍入为最接近的整数。例如ceil(21.2),返回23.</td> 
  </tr> 
  <tr> 
   <td align="left">double</td> 
   <td align="left">rand(), rand(int seed)</td> 
   <td align="left">返回大于或等于0且小于1的平均分布随机数（依重新计算而变）</td> 
  </tr> 
  <tr> 
   <td align="left">double</td> 
   <td align="left">exp(double a)</td> 
   <td align="left">返回e的n次方</td> 
  </tr> 
  <tr> 
   <td align="left">double</td> 
   <td align="left">ln(double a)</td> 
   <td align="left">返回给定数值的自然对数</td> 
  </tr> 
  <tr> 
   <td align="left">double</td> 
   <td align="left">log10(double a)</td> 
   <td align="left">返回给定数值的以10为底自然对数</td> 
  </tr> 
  <tr> 
   <td align="left">double</td> 
   <td align="left">log2(double a)</td> 
   <td align="left">返回给定数值的以2为底自然对数</td> 
  </tr> 
  <tr> 
   <td align="left">double</td> 
   <td align="left">log(double base, double a)</td> 
   <td align="left">返回给定底数及指数返回自然对数</td> 
  </tr> 
  <tr> 
   <td align="left">double</td> 
   <td align="left">pow(double a, double p) power(double a, double p)</td> 
   <td align="left">返回某数的乘幂</td> 
  </tr> 
  <tr> 
   <td align="left">double</td> 
   <td align="left">sqrt(double a)</td> 
   <td align="left">返回数值的平方根</td> 
  </tr> 
  <tr> 
   <td align="left">string</td> 
   <td align="left">bin(BIGINT a)</td> 
   <td align="left">返回二进制格式</td> 
  </tr> 
  <tr> 
   <td align="left">string</td> 
   <td align="left">hex(BIGINT a) hex(string a)</td> 
   <td align="left">将整数或字符转换为十六进制格式</td> 
  </tr> 
  <tr> 
   <td align="left">string</td> 
   <td align="left">unhex(string a)</td> 
   <td align="left">十六进制字符转换由数字表示的字符。</td> 
  </tr> 
  <tr> 
   <td align="left">string</td> 
   <td align="left">conv(BIGINT num, int from_base, int to_base)</td> 
   <td align="left">将指定数值，由原来的度量体系转换为指定的试题体系。例如CONV(‘a’,16,2),返回</td> 
  </tr> 
  <tr> 
   <td align="left">double</td> 
   <td align="left">abs(double a)</td> 
   <td align="left">取绝对值</td> 
  </tr> 
  <tr> 
   <td align="left">int double</td> 
   <td align="left">pmod(int a, int b) pmod(double a, double b)</td> 
   <td align="left">返回a除b的余数的绝对值</td> 
  </tr> 
  <tr> 
   <td align="left">double</td> 
   <td align="left">sin(double a)</td> 
   <td align="left">返回给定角度的正弦值</td> 
  </tr> 
  <tr> 
   <td align="left">double</td> 
   <td align="left">asin(double a)</td> 
   <td align="left">返回x的反正弦，即是X。如果X是在-1到1的正弦值，返回NULL。</td> 
  </tr> 
  <tr> 
   <td align="left">double</td> 
   <td align="left">cos(double a)</td> 
   <td align="left">返回余弦</td> 
  </tr> 
  <tr> 
   <td align="left">double</td> 
   <td align="left">acos(double a)</td> 
   <td align="left">返回X的反余弦，即余弦是X，，如果-1&lt;= A &lt;= 1，否则返回null.</td> 
  </tr> 
  <tr> 
   <td align="left">int double</td> 
   <td align="left">positive(int a) positive(double a)</td> 
   <td align="left">返回A的值，例如positive(2)，返回2。</td> 
  </tr> 
  <tr> 
   <td align="left">int double</td> 
   <td align="left">negative(int a) negative(double a)</td> 
   <td align="left">返回A的相反数，例如negative(2),返回-2。</td> 
  </tr> 
 </tbody> 
</table>

#### 二、类型转换函数 ####

<table> 
 <thead> 
  <tr> 
   <th align="left">返回类型</th> 
   <th align="left">函数</th> 
   <th align="left">说明</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td align="left">指定 “type”</td> 
   <td align="left">cast(expr as )</td> 
   <td align="left">类型转换。例如将字符”1″转换为整数:cast(’1′ as bigint)，如果转换失败返回NULL。</td> 
  </tr> 
 </tbody> 
</table>

#### 三、日期函数 ####

<table> 
 <thead> 
  <tr> 
   <th align="left">返回类型</th> 
   <th align="left">函数</th> 
   <th align="left">说明</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td align="left">string</td> 
   <td align="left">from_unixtime(bigint unixtime[, string format])</td> 
   <td align="left">UNIX_TIMESTAMP参数表示返回一个值’YYYY- MM – DD HH：MM：SS’或YYYYMMDDHHMMSS.uuuuuu格式，这取决于是否是在一个字符串或数字语境中使用的功能。该值表示在当前的时区。</td> 
  </tr> 
  <tr> 
   <td align="left">bigint</td> 
   <td align="left">unix_timestamp()</td> 
   <td align="left">如果不带参数的调用，返回一个Unix时间戳（从’1970- 01 – 0100:00:00′到现在的UTC秒数）为无符号整数。</td> 
  </tr> 
  <tr> 
   <td align="left">bigint</td> 
   <td align="left">unix_timestamp(string date)</td> 
   <td align="left">指定日期参数调用UNIX_TIMESTAMP（），它返回参数值’1970- 01 – 0100:00:00′到指定日期的秒数。</td> 
  </tr> 
  <tr> 
   <td align="left">bigint</td> 
   <td align="left">unix_timestamp(string date, string pattern)</td> 
   <td align="left">指定时间输入格式，返回到1970年秒数：unix_timestamp(’2009-03-20′, ‘yyyy-MM-dd’) = 1237532400</td> 
  </tr> 
  <tr> 
   <td align="left">string</td> 
   <td align="left">to_date(string timestamp)</td> 
   <td align="left">返回时间中的年月日： to_date(“1970-01-01 00:00:00″) = “1970-01-01″</td> 
  </tr> 
  <tr> 
   <td align="left">string</td> 
   <td align="left">to_dates(string date)</td> 
   <td align="left">给定一个日期date，返回一个天数（0年以来的天数）</td> 
  </tr> 
  <tr> 
   <td align="left">int</td> 
   <td align="left">year(string date)</td> 
   <td align="left">返回指定时间的年份，范围在1000到9999，或为”零”日期的0。</td> 
  </tr> 
  <tr> 
   <td align="left">int</td> 
   <td align="left">month(string date)</td> 
   <td align="left">返回指定时间的月份，范围为1至12月，或0一个月的一部分，如’0000-00-00′或’2008-00-00′的日期。</td> 
  </tr> 
  <tr> 
   <td align="left">int</td> 
   <td align="left">day(string date) dayofmonth(date)</td> 
   <td align="left">返回指定时间的日期</td> 
  </tr> 
  <tr> 
   <td align="left">int</td> 
   <td align="left">hour(string date)</td> 
   <td align="left">返回指定时间的小时，范围为0到23。</td> 
  </tr> 
  <tr> 
   <td align="left">int</td> 
   <td align="left">minute(string date)</td> 
   <td align="left">返回指定时间的分钟，范围为0到59。</td> 
  </tr> 
  <tr> 
   <td align="left">int</td> 
   <td align="left">second(string date)</td> 
   <td align="left">返回指定时间的秒，范围为0到59。</td> 
  </tr> 
  <tr> 
   <td align="left">int</td> 
   <td align="left">weekofyear(string date)</td> 
   <td align="left">返回指定日期所在一年中的星期号，范围为0到53。</td> 
  </tr> 
  <tr> 
   <td align="left">int</td> 
   <td align="left">datediff(string enddate, string startdate)</td> 
   <td align="left">两个时间参数的日期之差。</td> 
  </tr> 
  <tr> 
   <td align="left">int</td> 
   <td align="left">date_add(string startdate, int days)</td> 
   <td align="left">给定时间，在此基础上加上指定的时间段。</td> 
  </tr> 
  <tr> 
   <td align="left">int</td> 
   <td align="left">date_sub(string startdate, int days)</td> 
   <td align="left">给定时间，在此基础上减去指定的时间段。</td> 
  </tr> 
 </tbody> 
</table>

#### 四、条件函数 ####

<table> 
 <thead> 
  <tr> 
   <th align="left">返回类型</th> 
   <th align="left">函数</th> 
   <th align="left">说明</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td align="left">T</td> 
   <td align="left">if(boolean testCondition, T valueTrue, T valueFalseOrNull)</td> 
   <td align="left">判断是否满足条件，如果满足返回一个值，如果不满足则返回另一个值。</td> 
  </tr> 
  <tr> 
   <td align="left">T</td> 
   <td align="left">COALESCE(T v1, T v2, …)</td> 
   <td align="left">返回一组数据中，第一个不为NULL的值，如果均为NULL,返回NULL。</td> 
  </tr> 
  <tr> 
   <td align="left">T</td> 
   <td align="left">CASE a WHEN b THEN c [WHEN d THEN e]* [ELSE f] END</td> 
   <td align="left">当a=b时,返回c；当a=d时，返回e，否则返回f。</td> 
  </tr> 
  <tr> 
   <td align="left">T</td> 
   <td align="left">CASE WHEN a THEN b [WHEN c THEN d]* [ELSE e] END</td> 
   <td align="left">当值为a时返回b,当值为c时返回d。否则返回e。</td> 
  </tr> 
 </tbody> 
</table>

#### 五、字符串函数 ####

<table> 
 <thead> 
  <tr> 
   <th align="left">返回类型</th> 
   <th align="left">函数</th> 
   <th align="left">说明</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td align="left">int</td> 
   <td align="left">length(string A)</td> 
   <td align="left">返回字符串的长度</td> 
  </tr> 
  <tr> 
   <td align="left">string</td> 
   <td align="left">reverse(string A)</td> 
   <td align="left">返回倒序字符串</td> 
  </tr> 
  <tr> 
   <td align="left">string</td> 
   <td align="left">concat(string A, string B…)</td> 
   <td align="left">连接多个字符串，合并为一个字符串，可以接受任意数量的输入字符串</td> 
  </tr> 
  <tr> 
   <td align="left">string</td> 
   <td align="left">concat_ws(string SEP, string A, string B…)</td> 
   <td align="left">链接多个字符串，字符串之间以指定的分隔符分开。</td> 
  </tr> 
  <tr> 
   <td align="left">string</td> 
   <td align="left">substr(string A, int start) substring(string A, int start)</td> 
   <td align="left">从文本字符串中指定的起始位置后的字符。</td> 
  </tr> 
  <tr> 
   <td align="left">string</td> 
   <td align="left">substr(string A, int start, int len) substring(string A, int start, int len)</td> 
   <td align="left">从文本字符串中指定的位置指定长度的字符。</td> 
  </tr> 
  <tr> 
   <td align="left">string</td> 
   <td align="left">upper(string A) ucase(string A)</td> 
   <td align="left">将文本字符串转换成字母全部大写形式</td> 
  </tr> 
  <tr> 
   <td align="left">string</td> 
   <td align="left">lower(string A) lcase(string A)</td> 
   <td align="left">将文本字符串转换成字母全部小写形式</td> 
  </tr> 
  <tr> 
   <td align="left">string</td> 
   <td align="left">trim(string A)</td> 
   <td align="left">删除字符串两端的空格，字符之间的空格保留</td> 
  </tr> 
  <tr> 
   <td align="left">string</td> 
   <td align="left">ltrim(string A)</td> 
   <td align="left">删除字符串左边的空格，其他的空格保留</td> 
  </tr> 
  <tr> 
   <td align="left">string</td> 
   <td align="left">rtrim(string A)</td> 
   <td align="left">删除字符串右边的空格，其他的空格保留</td> 
  </tr> 
  <tr> 
   <td align="left">string</td> 
   <td align="left">regexp_replace(string A, string B, string C)</td> 
   <td align="left">字符串A中的B字符被C字符替代</td> 
  </tr> 
  <tr> 
   <td align="left">string</td> 
   <td align="left">regexp_extract(string subject, string pattern, int index)</td> 
   <td align="left">通过下标返回正则表达式指定的部分。regexp_extract(‘foothebar’, ‘foo(.*?)(bar)’, 2) returns ‘bar.’</td> 
  </tr> 
  <tr> 
   <td align="left">string</td> 
   <td align="left">parse_url(string urlString, string partToExtract [, string keyToExtract])</td> 
   <td align="left">返回URL指定的部分。parse_url(‘<a href="http://facebook.com/path1/p.php?k1=v1&amp;k2=v2#Ref1%E2%80%B2" rel="nofollow">http://facebook.com/path1/p.php?k1=v1&amp;k2=v2#Ref1′</a>, ‘HOST’) 返回：’<a href="http://facebook.com" rel="nofollow">facebook.com</a>’</td> 
  </tr> 
  <tr> 
   <td align="left">string</td> 
   <td align="left">get_json_object(string json_string, string path)</td> 
   <td align="left">select a.timestamp, get_json_object(a.appevents, ‘<span><span><span> . e v e n t i d ’ ) , g e t j s o n o b j e c t ( a . a p p e n v e t s , ‘ .eventid’), get_json_object(a.appenvets, ‘ </span><span><span><span style="height: 1.03611em; vertical-align: -0.286108em;"></span><span>.</span><span>e</span><span style="margin-right: 0.03588em;">v</span><span>e</span><span>n</span><span>t</span><span>i</span><span>d</span><span>’</span><span>)</span><span>,</span><span style="margin-right: 0.166667em;"></span><span style="margin-right: 0.03588em;">g</span><span>e</span><span><span>t</span><span><span><span><span style="height: 0.311664em;"><span style="top: -2.55em; margin-left: 0em; margin-right: 0.05em;"><span style="height: 2.7em;"></span><span><span style="margin-right: 0.05724em;">j</span></span></span></span><span></span></span><span><span style="height: 0.286108em;"><span></span></span></span></span></span></span><span>s</span><span>o</span><span><span>n</span><span><span><span><span style="height: 0.151392em;"><span style="top: -2.55em; margin-left: 0em; margin-right: 0.05em;"><span style="height: 2.7em;"></span><span><span>o</span></span></span></span><span></span></span><span><span style="height: 0.15em;"><span></span></span></span></span></span></span><span>b</span><span style="margin-right: 0.05724em;">j</span><span>e</span><span>c</span><span>t</span><span>(</span><span>a</span><span>.</span><span>a</span><span>p</span><span>p</span><span>e</span><span>n</span><span style="margin-right: 0.03588em;">v</span><span>e</span><span>t</span><span>s</span><span>,</span><span style="margin-right: 0.166667em;"></span><span>‘</span></span></span></span></span>.eventname’) from log a;</td> 
  </tr> 
  <tr> 
   <td align="left">string</td> 
   <td align="left">space(int n)</td> 
   <td align="left">返回指定数量的空格</td> 
  </tr> 
  <tr> 
   <td align="left">string</td> 
   <td align="left">repeat(string str, int n)</td> 
   <td align="left">重复N次字符串</td> 
  </tr> 
  <tr> 
   <td align="left">int</td> 
   <td align="left">ascii(string str)</td> 
   <td align="left">返回字符串中首字符的数字值</td> 
  </tr> 
  <tr> 
   <td align="left">string</td> 
   <td align="left">lpad(string str, int len, string pad)</td> 
   <td align="left">返回指定长度的字符串，给定字符串长度小于指定长度时，由指定字符从左侧填补。</td> 
  </tr> 
  <tr> 
   <td align="left">string</td> 
   <td align="left">rpad(string str, int len, string pad)</td> 
   <td align="left">返回指定长度的字符串，给定字符串长度小于指定长度时，由指定字符从右侧填补。</td> 
  </tr> 
  <tr> 
   <td align="left">array</td> 
   <td align="left">split(string str, string pat)</td> 
   <td align="left">将字符串转换为数组。</td> 
  </tr> 
  <tr> 
   <td align="left">int</td> 
   <td align="left">find_in_set(string str, string strList)</td> 
   <td align="left">返回字符串str第一次在strlist出现的位置。如果任一参数为NULL,返回NULL；如果第一个参数包含逗号，返回0。</td> 
  </tr> 
  <tr> 
   <td align="left">array&lt;array&gt;</td> 
   <td align="left">sentences(string str, string lang, string locale)</td> 
   <td align="left">将字符串中内容按语句分组，每个单词间以逗号分隔，最后返回数组。 例如sentences(‘Hello there! How are you?’) 返回：( (“Hello”, “there”), (“How”, “are”, “you”) )</td> 
  </tr> 
  <tr> 
   <td align="left">array&lt;struct&lt;string,double&gt;&gt;</td> 
   <td align="left">ngrams(array&lt;array&gt;, int N, int K, int pf)</td> 
   <td align="left">SELECT ngrams(sentences(lower(tweet)), 2, 100 [, 1000]) FROM twitter;</td> 
  </tr> 
  <tr> 
   <td align="left">array&lt;struct&lt;string,double&gt;&gt;</td> 
   <td align="left">context_ngrams(array&lt;array&gt;, array, int K, int pf)</td> 
   <td align="left">SELECT context_ngrams(sentences(lower(tweet)), array(null,null), 100, [, 1000]) FROM twitter;</td> 
  </tr> 
  <tr> 
   <td align="left"></td> 
   <td align="left"></td> 
   <td align="left"></td> 
  </tr> 
 </tbody> 
</table>

#### 六、聚合函数 ####

<table> 
 <thead> 
  <tr> 
   <th align="left">返回类型</th> 
   <th align="left">函数</th> 
   <th align="left">说明</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td align="left">bigint</td> 
   <td align="left">count(*) , count(expr), count(DISTINCT expr[, expr_., expr_.])</td> 
   <td align="left">返回记录条数。</td> 
  </tr> 
  <tr> 
   <td align="left">double</td> 
   <td align="left">sum(col), sum(DISTINCT col)</td> 
   <td align="left">求和</td> 
  </tr> 
  <tr> 
   <td align="left">double</td> 
   <td align="left">avg(col), avg(DISTINCT col)</td> 
   <td align="left">求平均值</td> 
  </tr> 
  <tr> 
   <td align="left">double</td> 
   <td align="left">min(col)</td> 
   <td align="left">返回指定列中最小值</td> 
  </tr> 
  <tr> 
   <td align="left">double</td> 
   <td align="left">max(col)</td> 
   <td align="left">返回指定列中最大值</td> 
  </tr> 
  <tr> 
   <td align="left">double</td> 
   <td align="left">var_pop(col)</td> 
   <td align="left">返回指定列的方差</td> 
  </tr> 
  <tr> 
   <td align="left">double</td> 
   <td align="left">var_samp(col)</td> 
   <td align="left">返回指定列的样本方差</td> 
  </tr> 
  <tr> 
   <td align="left">double</td> 
   <td align="left">stddev_pop(col)</td> 
   <td align="left">返回指定列的偏差</td> 
  </tr> 
  <tr> 
   <td align="left">double</td> 
   <td align="left">stddev_samp(col)</td> 
   <td align="left">返回指定列的样本偏差</td> 
  </tr> 
  <tr> 
   <td align="left">double</td> 
   <td align="left">covar_pop(col1, col2)</td> 
   <td align="left">两列数值协方差</td> 
  </tr> 
  <tr> 
   <td align="left">double</td> 
   <td align="left">covar_samp(col1, col2)</td> 
   <td align="left">两列数值样本协方差</td> 
  </tr> 
  <tr> 
   <td align="left">double</td> 
   <td align="left">corr(col1, col2)</td> 
   <td align="left">返回两列数值的相关系数</td> 
  </tr> 
  <tr> 
   <td align="left">double</td> 
   <td align="left">percentile(col, p)</td> 
   <td align="left">返回数值区域的百分比数值点。0&lt;=P&lt;=1,否则返回NULL,不支持浮点型数值。</td> 
  </tr> 
  <tr> 
   <td align="left">array</td> 
   <td align="left">percentile(col, array(p~1,\ [, p,2,]…))</td> 
   <td align="left">返回数值区域的一组百分比值分别对应的数值点。0&lt;=P&lt;=1,否则返回NULL,不支持浮点型数值。</td> 
  </tr> 
  <tr> 
   <td align="left">double</td> 
   <td align="left">percentile_approx(col, p[, B])</td> 
   <td align="left">Returns an approximate p<sup>th</sup> percentile of a numeric column (including floating point types) in the group. The B parameter controls approximation accuracy at the cost of memory. Higher values yield better approximations, and the default is 10,000. When the number of distinct values in col is smaller than B, this gives an exact percentile value.</td> 
  </tr> 
  <tr> 
   <td align="left">array</td> 
   <td align="left">percentile_approx(col, array(p~1, [, p,2_]…) [, B])</td> 
   <td align="left">Same as above, but accepts and returns an array of percentile values instead of a single one.</td> 
  </tr> 
  <tr> 
   <td align="left">array&lt;struct{‘x’,'y’}&gt;</td> 
   <td align="left">histogram_numeric(col, b)</td> 
   <td align="left">Computes a histogram of a numeric column in the group using b non-uniformly spaced bins. The output is an array of size b of double-valued (x,y) coordinates that represent the bin centers and heights</td> 
  </tr> 
  <tr> 
   <td align="left">array</td> 
   <td align="left">collect_set(col)</td> 
   <td align="left">返回无重复记录</td> 
  </tr> 
 </tbody> 
</table>

### explode 详解 ###

#### 一、概述 ####

1.  explode 命令可以将行数据，按指定规则切分出多行
2.  用explode做行切分，注意表里只有一列，并且行数据是string类型，因为只有字符类型才能做切分

#### 二、示例 ####

原始数据：  
100,200,300  
200,300,500  
要求：  
要将上面两行数据根据逗号拆分成多行（每个数字占一行）  
实现步骤

1.  上传HDFS，并创建对应的外部表，执行：

create external table ex1 (num string) location '/ex';

1.  通过explode指令来做行切分，执行：

select explode(split(num,',')) from ex1;

[2019032802400646.png]: /images/20220227/ca4bfff38519477eb3b72ef1f6ac1f9d.png
[20190328024000724.png]: /images/20220227/1099726973974059adf6cd81537e7331.png
[20190328023945949.png]: /images/20220227/d0c4b3391d2f4ebfa986f747f90dd2e1.png