Jho*_*hon 0 datetime scala jodatime dataframe apache-spark
环境:Spark 1.6;斯卡拉
简单的问题,但我没有得到准确的答案。我有一个数据框 DF
id | cr_date
-----------------------
1| 2017-03-17 11:12:00
----------------------
2|2017-03-17 15:10:00
Run Code Online (Sandbox Code Playgroud)
我需要从 cr_date 减去 5 分钟。我试过
val DF2= DF.select ($"cr_Date".cast("timestamp").minusMinutes(5)) // 不工作
有什么建议吗?谢谢
df.select(from_unixtime(unix_timestamp(col("cr_dt")).minus(5 * 60), "YYYY-MM-dd HH:mm:ss"))
Run Code Online (Sandbox Code Playgroud)
minusMinutesspark中没有这样的方法。上面的代码应该返回预期的结果。