配置单元中的sql我可以分区吗(my_partition=some_function())?

0kjbasz6  于 2021-06-26  发布在  Hive
关注(0)|答案(1)|浏览(251)

我的目标是:
处理昨天的数据,并将结果放入另一个表中。
所以我写了这个查询,但是 partition(d=my_yesterday()) 好像不行。

  1. insert overwrite table t1 partition(d=my_yesterday())
  2. select my_udtf(a, b, c) as (e, f, g, h) from t2
  3. where d=my_yesterday();
eqqqjvef

eqqqjvef1#

  1. set hive.mapred.mode=nonstrict
  2. ;
  3. insert overwrite table t1 partition(d)
  4. select m.*,t2.d
  5. from t2
  6. lateral view outer my_udtf(a, b, c) m as e, f, g, h
  7. where d=my_yesterday()
  8. ;

相关问题