Hive 系列（一）—— Hive 简介及核心概念

1、简介

Hive 是一个构建在 Hadoop 之上的数据仓库，它能够将结构化的数据文件映射成表，并提供类 SQL 查询功能，用于查询的 SQL 语句会被转化为 MapReduce 做业，而后提交到 Hadoop 上运行。

特色：

1. 简单、容易上手 (提供了相似 sql 的查询语言 hql)，使得精通 sql 可是不了解 Java 编程的人也能很好地进行大数据分析；
2. 灵活性高，能够自定义用户函数 (UDF) 和存储格式；
3. 为超大的数据集设计的计算和存储能力，集群扩展容易;
4. 统一的元数据管理，可与 presto／impala／sparksql 等共享数据；
5. 执行延迟高，不适合作数据的实时处理，但适合作海量数据的离线处理。

2、Hive的体系架构

2.1 command-line shell & thrift/jdbc

能够用 command-line shell 和 thrift／jdbc 两种方式来操做数据：

• command-line shell：经过 hive 命令行的的方式来操做数据；
• thrift／jdbc：经过 thrift 协议按照标准的 JDBC 的方式操做数据。

2.2 Metastore

在 Hive 中，表名、表结构、字段名、字段类型、表的分隔符等统一被称为元数据。全部的元数据默认存储在 Hive 内置的 derby 数据库中，但因为 derby 只能有一个实例，也就是说不能有多个命令行客户端同时访问，因此在实际生产环境中，一般使用 MySQL 代替 derby。

Hive 进行的是统一的元数据管理，就是说你在 Hive 上建立了一张表，而后在 presto／impala／sparksql 中都是能够直接使用的，它们会从 Metastore 中获取统一的元数据信息，一样的你在 presto／impala／sparksql 中建立一张表，在 Hive 中也能够直接使用。

2.3 HQL的执行流程

Hive 在执行一条 HQL 的时候，会通过如下步骤：

1. 语法解析：Antlr 定义 SQL 的语法规则，完成 SQL 词法，语法解析，将 SQL 转化为抽象 语法树 AST Tree；
2. 语义解析：遍历 AST Tree，抽象出查询的基本组成单元 QueryBlock；
3. 生成逻辑执行计划：遍历 QueryBlock，翻译为执行操做树 OperatorTree；
4. 优化逻辑执行计划：逻辑层优化器进行 OperatorTree 变换，合并没必要要的 ReduceSinkOperator，减小 shuffle 数据量；
5. 生成物理执行计划：遍历 OperatorTree，翻译为 MapReduce 任务；
6. 优化物理执行计划：物理层优化器进行 MapReduce 任务的变换，生成最终的执行计划。

关于 Hive SQL 的详细执行流程能够参考美团技术团队的文章：Hive SQL 的编译过程

3、数据类型

3.1 基本数据类型

Hive 表中的列支持如下基本数据类型：

大类	类型
Integers（整型）	TINYINT—1 字节的有符号整数 SMALLINT—2 字节的有符号整数 INT—4 字节的有符号整数 BIGINT—8 字节的有符号整数
Boolean（布尔型）	BOOLEAN—TRUE/FALSE
Floating point numbers（浮点型）	FLOAT— 单精度浮点型 DOUBLE—双精度浮点型
Fixed point numbers（定点数）	DECIMAL—用户自定义精度定点数，好比 DECIMAL(7,2)
String types（字符串）	STRING—指定字符集的字符序列 VARCHAR—具备最大长度限制的字符序列 CHAR—固定长度的字符序列
Date and time types（日期时间类型）	TIMESTAMP — 时间戳 TIMESTAMP WITH LOCAL TIME ZONE — 时间戳，纳秒精度 DATE—日期类型
Binary types（二进制类型）	BINARY—字节序列

TIMESTAMP 和 TIMESTAMP WITH LOCAL TIME ZONE 的区别以下：

• TIMESTAMP WITH LOCAL TIME ZONE：用户提交时间给数据库时，会被转换成数据库所在的时区来保存。查询时则按照查询客户端的不一样，转换为查询客户端所在时区的时间。
• TIMESTAMP ：提交什么时间就保存什么时间，查询时也不作任何转换。

3.2 隐式转换

Hive 中基本数据类型遵循如下的层次结构，按照这个层次结构，子类型到祖先类型容许隐式转换。例如 INT 类型的数据容许隐式转换为 BIGINT 类型。额外注意的是：按照类型层次结构容许将 STRING 类型隐式转换为 DOUBLE 类型。

3.3 复杂类型

类型	描述	示例
STRUCT	相似于对象，是字段的集合，字段的类型能够不一样，可使用 名称.字段名 方式进行访问	STRUCT ('xiaoming', 12 , '2018-12-12')
MAP	键值对的集合，可使用 名称[key] 的方式访问对应的值	map('a', 1, 'b', 2)
ARRAY	数组是一组具备相同类型和名称的变量的集合，可使用 名称[index] 访问对应的值	ARRAY('a', 'b', 'c', 'd')

3.4 示例

以下给出一个基本数据类型和复杂数据类型的使用示例：

CREATE TABLE students(
  name      STRING,   -- 姓名
  age       INT,      -- 年龄
  subject   ARRAY<STRING>,   --学科
  score     MAP<STRING,FLOAT>,  --各个学科考试成绩
  address   STRUCT<houseNumber:int, street:STRING, city:STRING, province：STRING>  --家庭居住地址
) ROW FORMAT DELIMITED FIELDS TERMINATED BY "\t";

4、内容格式

当数据存储在文本文件中，必须按照必定格式区别行和列，如使用逗号做为分隔符的 CSV 文件 (Comma-Separated Values) 或者使用制表符做为分隔值的 TSV 文件 (Tab-Separated Values)。但此时也存在一个缺点，就是正常的文件内容中也可能出现逗号或者制表符。

因此 Hive 默认使用了几个平时不多出现的字符，这些字符通常不会做为内容出如今文件中。Hive 默认的行和列分隔符以下表所示。

分隔符	描述
\n	对于文本文件来讲，每行是一条记录，因此可使用换行符来分割记录
^A (Ctrl+A)	分割字段 (列)，在 CREATE TABLE 语句中也可使用八进制编码 \001 来表示
^B	用于分割 ARRAY 或者 STRUCT 中的元素，或者用于 MAP 中键值对之间的分割， 在 CREATE TABLE 语句中也可使用八进制编码 \002 表示
^C	用于 MAP 中键和值之间的分割，在 CREATE TABLE 语句中也可使用八进制编码 \003 表示

使用示例以下：

CREATE TABLE page_view(viewTime INT, userid BIGINT)
 ROW FORMAT DELIMITED
   FIELDS TERMINATED BY '\001'
   COLLECTION ITEMS TERMINATED BY '\002'
   MAP KEYS TERMINATED BY '\003'
 STORED AS SEQUENCEFILE;

5、存储格式

5.1 支持的存储格式

Hive 会在 HDFS 为每一个数据库上建立一个目录，数据库中的表是该目录的子目录，表中的数据会以文件的形式存储在对应的表目录下。Hive 支持如下几种文件存储格式：

格式	说明
TextFile	存储为纯文本文件。 这是 Hive 默认的文件存储格式。这种存储方式数据不作压缩，磁盘开销大，数据解析开销大。
SequenceFile	SequenceFile 是 Hadoop API 提供的一种二进制文件，它将数据以<key,value>的形式序列化到文件中。 这种二进制文件内部使用 Hadoop 的标准的 Writable 接口实现序列化和反序列化。它与 Hadoop API 中的 MapFile 是互相兼容的。 Hive 中的 SequenceFile 继承自 Hadoop API 的 SequenceFile，不过它的 key 为空，使用 value 存放实际的值， 这样是为了不 MR 在运行 map 阶段进行额外的排序操做。
RCFile	RCFile 文件格式是 FaceBook 开源的一种 Hive 的文件存储格式，首先将表分为几个行组， 对每一个行组内的数据按列存储，每一列的数据都是分开存储。
ORC Files	ORC 是在必定程度上扩展了 RCFile，是对 RCFile 的优化。
Avro Files	Avro 是一个数据序列化系统，设计用于支持大批量数据交换的应用。 它的主要特色有：支持二进制序列化方式，能够便捷，快速地处理大量数据； 动态语言友好，Avro 提供的机制使动态语言能够方便地处理 Avro 数据。
Parquet	Parquet 是基于 Dremel 的数据模型和算法实现的，面向分析型业务的列式存储格式。 它经过按列进行高效压缩和特殊的编码技术，从而在下降存储空间的同时提升了 IO 效率。

以上压缩格式中 ORC 和 Parquet 的综合性能突出，使用较为普遍，推荐使用这两种格式。

5.2 指定存储格式

一般在建立表的时候使用 STORED AS 参数指定：

CREATE TABLE page_view(viewTime INT, userid BIGINT)
 ROW FORMAT DELIMITED
   FIELDS TERMINATED BY '\001'
   COLLECTION ITEMS TERMINATED BY '\002'
   MAP KEYS TERMINATED BY '\003'
 STORED AS SEQUENCEFILE;

各个存储文件类型指定方式以下：

• STORED AS TEXTFILE
• STORED AS SEQUENCEFILE
• STORED AS ORC
• STORED AS PARQUET
• STORED AS AVRO
• STORED AS RCFILE

6、内部表和外部表

内部表又叫作管理表 (Managed/Internal Table)，建立表时不作任何指定，默认建立的就是内部表。想要建立外部表 (External Table)，则须要使用 External 进行修饰。 内部表和外部表主要区别以下：

	内部表	外部表
数据存储位置	内部表数据存储的位置由 hive.metastore.warehouse.dir 参数指定，默认状况下表的数据存储在 HDFS 的 /user/hive/warehouse/数据库名.db/表名/ 目录下	外部表数据的存储位置建立表时由 Location 参数指定；
导入数据	在导入数据到内部表，内部表将数据移动到本身的数据仓库目录下，数据的生命周期由 Hive 来进行管理	外部表不会将数据移动到本身的数据仓库目录下，只是在元数据中存储了数据的位置
删除表	删除元数据（metadata）和文件	只删除元数据（metadata）

参考资料

1. Hive Getting Started
2. Hive SQL 的编译过程
3. LanguageManual DDL
4. LanguageManual Types
5. Managed vs. External Tables

更多大数据系列文章能够参见 GitHub 开源项目： 大数据入门指南