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


免责声明!

本站转载的文章为个人学习借鉴使用,本站对版权不负任何法律责任。如果侵犯了您的隐私权益,请联系本站邮箱yoyou2525@163.com删除。



 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM