步骤:建分区表、建临时表、临时表数据写入、临时表写入数据到分区表
1、分区参数介绍
-
hive.exec.dynamic.partition:是否启动动态分区。默认false。
-
hive.exec.dynamic.partition.mode:打开动态分区后,动态分区的模式为strict和nonstrict。
-
strict可设置为静态和半动态,要求至少包含一个静态分区列。
-
nonstrict可设置为静态、半动态和动态,动态必须设置此参数。
-
-
hive.exec.max.dynamic.partitions:允许的最大的动态分区的个数。默认1000。
-
hive.exec.max.dynamic.partitions.pernode:一个mapreduce job所允许的最大的动态分区的个数。默认是100。
2、分区表的创建
(1)分区表创建
create table test.user_list( user_id string, msisdn string, imsi string) partitioned by (city string,sdate string) row format delimited fields terminated by ',';
(2)临时表创建(辅助分区表测试)
create table test.user_list_tmp( user_id string, msisdn string, imsi string city string, sdate string) row format delimited fields terminated by ',';
3、数据插入方式
(1)静态分区插入数据:
insert into table user_list partition(city='HANGZHOU',sdate='20200101') select t.user_id, t.msisdn, t.imsi from test.user_list_tmp t
(2)动静混合分区插入数据
set hive.exec.dynamic.partition=true; set hive.exec.dynamic.partition.mode=strick; --set hive.exec.dynamic.partition.mode=nonstrick; insert into table user_list partition(city='HANGZHOU',sdate='${sdate}') select t.user_id, t.msisdn, t.imsi, t.sdate from test.user_list_tmp t
注意:动静分区混合时,静态分区参数必须放置在前面。
(3)动态分区插入数据
set hive.exec.dynamic.partition=true; set hive.exec.dynamic.partition.mode=nonstrick; insert into table user_list partition(city='${city}',sdate='${sdate}') select t.user_id, t.msisdn, t.imsi, t.city, t.sdate from test.user_list_tmp t
4、insert into 和 insert overwrite
insert into示例:
insert into table user_list partition(city='HANGZHOU',sdate='20200101') select t.user_id, t.msisdn, t.imsi from test.user_list_tmp t
insert overwrite示例:
insert overwrite table user_list partition(city='HANGZHOU',sdate='20200101') select t.user_id, t.msisdn, t.imsi from test.user_list_tmp t
两者区别:insert into直接追加到表中数据的尾部,而insert overwrite会重写数据,既先进行删除,再写入。
转自:http://blog.sina.com.cn/s/blog_155cf0b760102x1ij.html