问使用Spark sql检查当前日期
EN

Stack Overflow用户

提问于 2016-08-25 23:04:58

回答 1查看 3.5K关注 0票数 0

我正在尝试在spark dataframe(scala)中进行过滤，以检查某列是否少于当天。

myDataFrame.filter(myDataFrame("expiry_date").lt(CurrentDate))

但是它抛出了下面的错误

"message": "java.lang.RuntimeException: Unsupported literal type class org.apache.spark.sql.catalyst.expressions.CurrentDate$ CurrentDate"

对此有什么想法吗？

发布于 2016-08-26 01:18:13

下面的内容应该可以用

myDataFrame.filter(myDataFrame("expiry_date").lt(current_date()))

如果您有java.util.Date，则使用以下命令

java.util.Date currDate = new java.util.Date();
myDataFrame.filter(myDataFrame("expiry_date").lt(new java.sql.Date(currDate.getTime())))

票数 0

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/39148754

复制

相似问题

问使用Spark sql检查当前日期EN