hive多分区表创建+数据导入

步骤：建分区表、建临时表、临时表数据写入、临时表写入数据到分区表

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