SparkSQL如何对时间字段进行加减

Question

我有 SparkSQl csreipdt 。与数据框其中。基于 SQL select 的连接

val df_t =   sparkSession.sqlContext.sql(" select datetime from table")

我需要返回与datetime+ 1 分钟和datetime - 1 分钟相同的日期时间，我找不到如何执行此操作的解决方案？有任何想法吗？

Answer 1

你能用间隔吗？

spark.sql("""SELECT current_timestamp() - INTERVAL 1 MINUTE, current_timestamp() + INTERVAL 1 MINUTE""").show(false)