2017-09-28 55 views
0

我的目標是:在Hive中。我可以分區(my_partition = some_function())嗎?

處理昨天的數據,並把結果放到另一個表中。

所以我寫了這個查詢,但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(); 
+0

您正在使用UDF爲了得到昨天日期的原因是什麼? –

回答

0
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() 
; 
相關問題