从Spark SQL中的字符串日期时间获取年份

Question

我试图通过使用文档中的year（）函数来获得spark SQL年。

名为dt的日期时间字符串的格式类似于dd/MM/yyyy。

我已经尝试进行如下查询以获取2018年和2019年的所有记录：

SELECT * FROM T1
WHERE year(dt) == 2018 AND year(dt=='2019');

但似乎有些事情是错的。有什么建议？

Answer 1

我相信你在问一些不可能的事情。您告诉该计划在2018年和2019年同时获得。请尝试以下方法：

SELECT * FROM T1
WHERE year([dt]) in (2018, 2019)

我希望它有助于BR