Spark:计算时间差(天数和秒数)
生活随笔
收集整理的這篇文章主要介紹了
Spark:计算时间差(天数和秒数)
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
//天數時間差
table.select(datediff(table.col("Start Time"), table.col("End Time"))).show()
//描述時間差
import org.apache.spark.sql.functions._//For $notation columns // Spark 2.0
import spark.implicits._table.withColumn("date_diff", (unix_timestamp($"Start Time") - unix_timestamp($"End Time"))
).show()
總結
以上是生活随笔為你收集整理的Spark:计算时间差(天数和秒数)的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: Spark:获取dataframe某列最
- 下一篇: Spark DataFrame 添加自增