我已在中插入覆盖查询 HIVE 1.2.1 version
. 我想在配置单元中使用更新而不是插入覆盖。
有人能在hive update中给出建议或示例吗?下面是我使用的插入覆盖查询示例。
Insert overwrite table temporary_table
select distinct
stg.col1,
stg.col2,
stg.col3,
case when tgt.cr_ts is Null then from_unixtime(unix_timestamp()) else cast(tgt.cr_ts as string) end as cr_ts ,
case when ( stg.col1=tgt.col1 and
stg.col2=tgt.col2 and
stg.col3= tgt.col3 )
then cast(tgt.last_updt_ts as string) else cast (from_unixtime(unix_timestamp()) as string )end as last_updt_ts
from stage_table stg
left outer join target_table tgt
On ( stg.col1= tgt.col1);
暂无答案!
目前还没有任何答案,快来回答吧!