scala—在Dataframe中转换时间戳格式

pcrecxhr  于 2021-05-16  发布在  Spark
关注(0)|答案(2)|浏览(998)

我读了一个csv文件并制作了一个Dataframe,其中timestamp列的格式是“11/12/2020 3:01”。
如何将其转换为“yyyy-mm-dd hh:mm:ss.ssssss”格式以用于特定时间戳列的数据?

ct3nt3jp

ct3nt3jp1#

import org.apache.spark.sql.functions._

df.withColumn("timestamp_col",
    date_format(
        unix_timestamp($"timestamp_col", "dd/MM/yyyy h:mm").cast("timestamp"),  
    "yyyy-MM-dd hh:mm:ss.SSSSSS")
)
k10s72fa

k10s72fa2#

注意文档中的.strftimehttps://docs.python.org/3/library/datetime.html
timestamp.strftime(“%d.%m.%y”)

相关问题