想向hive二级分区表中用insert插入数据,Partition的值是从另外的表中拿,且拿来以后还需要用到函数处理一下, 该怎么操作?
建表语句
CREATE TABLE IF NOT EXISTS t
(
company_key BIGINT COMMENT '源数据无备注',
trade_uid STRING COMMENT '源数据无备注',
trade_no STRING COMMENT '源数据无备注'
)
COMMENT '表(以dm+pt做分区)'
PARTITIONED BY
(
d BIGINT COMMENT '年月 202001',
p STRING COMMENT '公司id后三位 666'
);
无运行
无思路
p分区需要用到SUBSTR()函数
使用动态分区
set hive.exec.dynamic.partition=true;
set hive.exec.dynamic.partition.mode=nonstrict;
insert overwrite table 结果表 partition(d,p)
select
company_key ,trade_uid ,trade_no
,d -- 分区一
,substr(p,1,7) as p -- 分区2
from t