![]() |
面冷心慈的马铃薯 · 《琵琶行》里的虾蟆陵葬的是谁?_手机搜狐网· 6 月前 · |
![]() |
细心的沙滩裤 · “蒙古语语料库”建设取得重大成果--24小时 ...· 1 年前 · |
![]() |
安静的饭盒 · 鸿蒙手机卸载内置应用adb连接_鸿蒙系统ad ...· 1 年前 · |
![]() |
俊秀的鼠标垫 · 搞定压力和压强!初中物理- 知乎· 1 年前 · |
![]() |
开朗的野马 · 一个14岁孤女的寻父之旅:我只是想叫他一声爸 ...· 1 年前 · |
我正在尝试在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())))
https://stackoverflow.com/questions/39148754
复制相似问题
扫码关注腾讯云开发者
领取腾讯云代金券
Copyright © 2013 - 2024 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号: 粤B2-20090059 深公网安备号 44030502008569
腾讯云计算(北京)有限责任公司 京ICP证150476号 | 京ICP备11018762号 | 京公网安备号11010802020287
![]() |
面冷心慈的马铃薯 · 《琵琶行》里的虾蟆陵葬的是谁?_手机搜狐网 6 月前 |
![]() |
俊秀的鼠标垫 · 搞定压力和压强!初中物理- 知乎 1 年前 |
![]() |
开朗的野马 · 一个14岁孤女的寻父之旅:我只是想叫他一声爸爸- 知乎 1 年前 |