本文主要是翻译Hive官网关于Load的解释,原文来源于:https://cwiki.apache.org/confluence/display/Hive/LanguageManual+DML#LanguageManualDML-Loadingfilesintotablesnode
介绍
Hive Load语句不会在加载数据的时候作任何转换工做,而是纯粹的把数据文件复制/移动到Hive表对应的地址。apache
语法
LOAD DATA [LOCAL] INPATH 'filepath' [OVERWRITE] INTO TABLE tablename [PARTITION (partcol1=val1,partcol2=val2 ...)]
1
描述
filepath 能够是:
相对路径,如project/data1
绝对路径,如/user/hive/project/data1
完整的URL,如hdfs://namenode:9000/user/hive/project/data1
目标能够是一个表或是一个分区。若是目标表是分区表,必须指定是要加载到哪一个分区。
filepath 能够是一个文件,也能够是一个目录(会将目录下的全部文件都加载)。
若是命令中带LOCAL,表示:
load命令从本地文件系统中加载数据,能够是相对路径,也能够是绝对路径。对于本地文件系统,也可使用完整的URL,如file:///user/hive/project/data1
load命令会根据指定的本地文件系统中的filepath复制文件到目标文件系统,而后再移到对应的表
若是命令中没有LOCAL,表示从HDFS加载文件,filepath可使用完整的URL方式,或者使用fs.default.name定义的值
命令带OVERWRITE时加载数据以前会先清空目标表或分区中的内容,不然就是追加的方式。
--------------------- app
insert 语法格式为:oop
1. 基本的插入语法:post
insert overwrite table tablename [partition(partcol1=val1,partclo2=val2)] select_statement;.net
insert into table tablename [partition(partcol1=val1,partclo2=val2)] select_statement;翻译
eg:blog
insert overwrite table test_insert select * from test_table;
insert into table test_insert select * from test_table;ip
注:
overwrite重写,into追加。hadoop
2. 对多个表进行插入操做:
from source_table
insert overwrite table tablename1 [partition (partcol1=val1,partclo2=val2)] select_statement1
insert overwrite table tablename2 [partition (partcol1=val1,partclo2=val2)] select_statement2
eg:
from test_table
insert overwrite table test_insert1
select key
insert overwrite table test_insert2
select value;
注:hive不支持用insert语句一条一条的进行插入操做,也不支持update操做。数据是以load的方式加载到创建好的表中,数据一旦导入就不能够修改。
2.经过查询将数据保存到filesystem
insert overwrite [local] directory 'directory' select_statement;
eg:
(1)导入数据到本地目录:
insert overwrite local directory '/home/hadoop/data' select * from test_insert1;
产生的文件会覆盖指定目录中的其余文件,即将目录中已经存在的文件进行删除。
只能用overwrite,into错误!
(2)导出数据到HDFS中:
insert overwrite directory '/user/hive/warehouse/table' select value from test_table;
只能用overwrite,into错误!
(3)同一个查询结果能够同时插入到多个表或者多个目录中:
from source_table
insert overwrite local directory '/home/hadoop/data' select *
insert overwrite directory '/user/hive/warehouse/table' select value;
3. 小结:
(1)insert命令主要用于将hive中的数据导出,导出的目的地能够是hdfs或本地filesysytem,导入什么数据在于书写的select语句。
(2)overwrite与into:
insert overwrite/intotable能够搭配;
insert overwritedirectory能够搭配;
Hive 加载数据主要有两种方式,一种是用Load直接加载文件,能够是从本地文件系统,也能够是从HDFS文件系统;Load方式不作任何的转换,只是纯粹的文件复制移动,关于Load加载详情,请见个人另外一篇文章: http://blog.csdn.net/post_yuan/article/details/62883565
除了Load加载数据,Hive也支持Insert命令,下面就来详细介绍Hive不一样的版本在Insert方面的支持和改进,
标准语法
INSERT OVERWRITE TABLE tablename [PARTITION (partcol1=val1, partcol2=val2 ...)] select_statement1 FROM from_statement;
INSERT INTO TABLE tablename [PARTITION (partcol1=val1, partcol2=val2 ...)] select_statement1 FROM from_statement;
INSERT INTO TABLE tablename [PARTITION (partcol1=val1, partcol2=val2 ...)](z, y) select_statement1 FROM from_statement;
1
2
3
高级语法(Multiple Inserts)
FROM from_statement
INSERT OVERWRITE TABLE tablename [PARTITION (partcol1=val1, partcol2=val2 ...)] select_statement1
[INSERT OVERWRITE TABLE tablename2 [PARTITION ...] select_statement2]
[INSERT INTO TABLE tablename2 [PARTITION ...] select_statement2];
1
2
3
4
高级语法(Dynamic Partition Inserts)
INSERT OVERWRITE TABLE tablename PARTITION (partcol1[=val1], partcol2[=val2] ...) select_statement FROM from_statement;
INSERT INTO TABLE tablename PARTITION (partcol1[=val1], partcol2[=val2] ...) select_statement FROM from_statement;
1
2
描述
INSERT OVERWRITE会覆盖表或分区中已存在的数据
INSERT INTO以追加数据的方式插入到表或分区,原有数据不会删除
Insert能够插入表或分区,若是表是分区表,则Insert时须要指定插入到哪一个分区
从Hive 1.1.0版本,TABLE关键字是可选的
从Hive 1.2.0版本,INSERT INTO能够指定插入到哪些字段中,如INSERT INTO t(x,y,z)
动态分区插入
当INSERT往分区表插入数据时,咱们能够指定分区字段名和值,分区字段的值是可选的,若是指定分区字段值,咱们称之为静态分区,不然称之为动态分区。动态分区建立根据插入数据的列决定。在Hive 0.9.0版本之前,动态分区插入默认是关闭的,在Hive 0.9.0版本及更高版本,默认是打开的。关于动态分区插入,有几个相关的配置:
参数 默认值 注释
hive.exec.dynamic.partition true 设置为true表示启用动态分区插入
hive.exec.dynamic.partition.mode strict strict模式时用户必须至少指定一个静态分区;nonstrict模式时全部分区均可能是动态分区
hive.exec.max.dynamic.partitions.pernode 100 每一个mapper/reducer节点容许建立的最大动态分区数
hive.exec.max.dynamic.partitions 1000 总共容许建立的最大动态分区数
hive.exec.max.created.files 100000 一个MR job中容许建立多少个HDFS文件
hive.error.on.empty.partition false 当动态分区插入产生空值时是否抛出异常
从查询语句写入到文件系统
Hive支持从查询语句直接写入到文件系统,此处不作详细介绍
INSERT VALUES
Hive 0.14版本开始,支持INSERT…VALUES语法,具体语法以下,
INSERT INTO TABLE tablename [PARTITION (partcol1[=val1], partcol2[=val2] ...)] VALUES values_row [, values_row ...]
values_row: (value [, value ...]) value能够为null或者任意SQL语法