apache-spark - Spark sql 日期添加

Question

我正在尝试过滤掉从当前日期到最近 3 年的数据，并尝试将其用于 spark sql 查询:(例如:d_date 列格式 2009-09-18 )

WHERE d_date >= DATEADD(MONTH, -3, GETDATE())

但出现以下错误。

Undefined function: 'DATEADD'. This function is neither a registeredtemporary function nor a permanent function registered in the database'default'.;

spark SQL 是否有任何 DATEADD 等效项？

Answer 1

Spark SQL 有 date_add功能，它与您尝试使用的功能不同，因为它只需几天即可添加。

对于您的情况，您可以使用 add_months添加 -36 = 3 年

WHERE d_date >= add_months(current_date(), -36)