Beeline中的Date函数

Question

我试图在我的自动化脚本中添加一个日期函数，以便每个月运行前一个月的数据。当我试图单独运行下面的查询时，它可以工作。

Select add_months(trunc(FROM_UNIXTIME(UNIX_TIMESTAMP()),'MM'),-1),  
date_sub(concat(from_unixtime(unix_timestamp(), 'yyyy-MM'), '-01'), 1);
+-------------+-------------+--+
|     _c0     |     _c1     |
+-------------+-------------+--+
| 2018-03-01  | 2018-03-31  |
+-------------+-------------+--+
1 row selected (6.697 seconds)

但是，当我试图在我的直线查询中添加相同的“Where”过滤器时，它不会抛出任何错误和停止，但是执行该查询需要很长的时间(小时和小时)，并最终一个接一个地终止。

where date_vairable between add_months(trunc(FROM_UNIXTIME(UNIX_TIMESTAMP()),'MM'),-1) and  
date_sub(concat(from_unixtime(unix_timestamp(), 'yyyy-MM'), '-01'), 1);

我们非常感谢你的帮助。提前谢谢！

Answer 1

假设您的where子句应该筛选前一个月的行，请使用

where date_vairable between 
add_months(trunc(FROM_UNIXTIME(UNIX_TIMESTAMP()),'MM'),-1) and  
date_sub(trunc(FROM_UNIXTIME(UNIX_TIMESTAMP()),'MM'),1)

或者用更简洁的方式表达

date_vairable between add_months(trunc(current_date,'MM'),-1)
and date_add(trunc(current_date,'MM'),-1)