|
|
相关文章推荐
|
高大的毛衣 · 将 Entity ...· 1 月前 · |
|
|
失落的棒棒糖 · Java项目整合MapStruct - 知乎· 1 年前 · |
|
|
深沉的蚂蚁 · 面向区域交通状态预测的时空集成模型· 1 年前 · |
|
|
淡定的斑马 · python中readline判断文件读取结 ...· 2 年前 · |
使用Spark sql检查当前日期
问
使用Spark sql检查当前日期
EN
EN
Stack Overflow用户
提问于
2016-08-25 23:04:58
回答 1
查看 3.5K
关注 0
票数 0
我正在尝试在spark dataframe(scala)中进行过滤，以检查某列是否少于当天。
代码语言：
javascript
复制
myDataFrame.filter(myDataFrame("expiry_date").lt(CurrentDate))但是它抛出了下面的错误
代码语言：
javascript
复制
"message": "java.lang.RuntimeException: Unsupported literal type class org.apache.spark.sql.catalyst.expressions.CurrentDate$ CurrentDate"对此有什么想法吗？
EN
回答 1
Stack Overflow用户
发布于 2016-08-26 01:18:13
下面的内容应该可以用
代码语言：
javascript
复制
myDataFrame.filter(myDataFrame("expiry_date").lt(current_date()))如果您有java.util.Date，则使用以下命令
代码语言：
javascript
复制
java.util.Date currDate = new java.util.Date();
myDataFrame.filter(myDataFrame("expiry_date").lt(new java.sql.Date(currDate.getTime())))
票数 0
EN
页面原文内容由
Stack Overflow
提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/39148754
复制
相关文章
相似问题
领券
腾讯云开发者
扫码关注腾讯云开发者
领取腾讯云代金券
Copyright © 2013 - 2024 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号： 粤B2-20090059 深公网安备号 44030502008569
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号 | 京公网安备号11010802020287