我的目标是:处理昨天的数据,并将结果放入另一个表中。所以我写了这个查询,但是 partition(d=my_yesterday()) 好像不行。
partition(d=my_yesterday())
insert overwrite table t1 partition(d=my_yesterday()) select my_udtf(a, b, c) as (e, f, g, h) from t2 where d=my_yesterday();
insert overwrite table t1 partition(d=my_yesterday())
select my_udtf(a, b, c) as (e, f, g, h) from t2
where d=my_yesterday();
eqqqjvef1#
set hive.mapred.mode=nonstrict;insert overwrite table t1 partition(d)select m.*,t2.dfrom t2 lateral view outer my_udtf(a, b, c) m as e, f, g, hwhere d=my_yesterday();
set hive.mapred.mode=nonstrict
;
insert overwrite table t1 partition(d)
select m.*,t2.d
from t2
lateral view outer my_udtf(a, b, c) m as e, f, g, h
where d=my_yesterday()
1条答案
按热度按时间eqqqjvef1#