Sparksql 日期加減函數

1、日期加減
spark sql 日期加減，date_sub,date_add

val dateDF=spark.range(10)
.withColumn("today",current_date())
.withColumn("now",current_timestamp())
dateDF.createOrReplaceTempView("dateTable")
dateDF.printSchema()
dateDF.select(date_sub(col("today"),5),date_add(col("today"),5)).show(1)
spark.sql("select date_sub(today,5),date_add(today,5) from dateTable").show(1)

 2、計算兩個日期之間相差的天數  （datediff）

datediff(endDate,startDate)

datediff(LEAST('" + getDateNow() + "',end_date),f_due_date)
spark.sql("select datediff('2019-11-09','2019-11-08') ").show()  // 1
spark.sql("select datediff('2019-11-09','2019-10-08') ").show()  //32

https://www.cnblogs.com/feiyumo/p/8760846.html

sparksql 內置日期時間函數
http://bcxw.net/article/543.html