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)
    原文作者:王社英
    原文地址: https://www.jianshu.com/p/30739ef0a04e
    本文转自网络文章,转载此文章仅为分享知识,如有侵权,请联系博主进行删除。
点赞