我试图过滤掉从当前日期到最近3年的数据，并尝试将其用于spark sql查询：（例如： d_date 列格式 2009-09-18 )
WHERE d_date >= DATEADD(MONTH, -3, GETDATE())但得到以下错误。
未定义函数：“dateadd”。此函数既不是已注册的临时函数，也不是在数据库“default”中注册的永久函数。；
对于sparksql有没有dateadd等价物？
我试图过滤掉从当前日期到最近3年的数据，并尝试将其用于spark sql查询：（例如： d_date 列格式 2009-09-18 )
WHERE d_date >= DATEADD(MONTH, -3, GETDATE())但得到以下错误。
未定义函数：“dateadd”。此函数既不是已注册的临时函数，也不是在数据库“default”中注册的永久函数。；
对于sparksql有没有dateadd等价物？
1条答案
按热度按时间cedebl8k1#
spark sql有
date_add函数，并且它与您尝试使用的函数不同，因为添加它只需要几天时间。你可以用
add_months添加-36 = 3 years```WHERE d_date >= add_months(current_date(), -36)