使用pyspark将unix_timestamp列转换为字符串

Question

我有一个代表unix_timestamp的列，并希望将其转换为这种格式的字符串'yyyy-MM-dd HH：mm：ss.SSS'。

unix_timestamp | time_string

1578569683753  | 2020-01-09 11:34:43.753
1578569581793  | 2020-01-09 11:33:01.793
1578569581993  | 2020-01-09 11:33:01.993

是否有任何内置函数或它如何工作？谢谢。

Answer 1

df1 = df1.withColumn('utc_stamp', F.from_unixtime('Timestamp', format="YYYY-MM-dd HH:mm:ss"))

df1.show(truncate=False)

from_unixtime只能转换为秒，毫秒只需要将它们从原始列连接到新列。