Scala Spark中24小時格式的DateTime轉換

Question

我用以下方式在dataframe中格式化了時間戳。

var df_v_5 = df_v_4..withColumn("endTimeFormat", 
from_unixtime(unix_timestamp('DateTime), "dd-MM-yyyy hh:mm:ss")) 

我正在爲

DateTime,value1,value2,endTimeFormat 
2017-01-01T12:00:00.000+05:30,11,-14,01-01-2017 12:00:00 
2017-01-01T13:00:00.000+05:30,110,13,01-01-2017 01:00:00 

輸出預計輸出：

DateTime,value1,value2,endTimeFormat 
2017-01-01T12:00:00.000+05:30,11,-14,01-01-2017 12:00:00 
2017-01-01T13:00:00.000+05:30,110,13,01-01-2017 13:00:00 

我如何轉換這個時間戳爲24小時格式？

Answer 1

//Maybe try to make the hh to uppercase 
val df = spark.sql("SELECT from_unixtime(unix_timestamp('01-01-2017 12:59:59', 'dd-MM-yyyy hh:mm:ss'), 'dd-MM-yyyy HH:mm:ss')") 

df.collect().foreach(println(_)) 

// result 
[01-01-2017 00:59:59]