pyspark - 使用 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

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

标签： pysparkunix-timestampepoch

Answer 1

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

df1.show(truncate=False)

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