pyspark：用微秒将bigint转换为时间戳

iezvtpos 于 2021-05-16 发布在 Spark

关注(0)|答案(1)|浏览(609)

我想把一个 bigint unix时间戳 datetime 格式 "yyyy-MM-dd HH:mm:ss:SSSSSS" 包括微秒。当我使用标准的todatetime函数时，我得到如下结果

spark.sql("select to_timestamp(1605509165022529) as ts").show(truncate=False)

结果

+----------------------------+
|ts                          |
+----------------------------+
|22327-10-26 13:09:588.009408|
+----------------------------+

这个 datetime 这是错误的。日期应为2020-11-16，时间为 HH:mm:ss:SSSSSS .
我怎么能得到这个？

sql python apache-spark pyspark apache-spark-sql

来源：https://stackoverflow.com/questions/65124408/pyspark-convert-bigint-to-timestamp-with-microseconds

1条答案

按热度按时间

bfnvny8b1#

将时间戳除以1e6，因为 to_timestamp unix时间戳的单位应为秒，而不是微秒。

spark.sql("select to_timestamp(1605509165022529/1e6) as ts").show(truncate=False)

+--------------------------+
|ts                        |
+--------------------------+
|2020-11-16 06:46:05.022529|
+--------------------------+

赞(0）回复(0）举报 2021-05-17

我来回答

pyspark：用微秒将bigint转换为时间戳

1条答案

相关问题

热门标签

最新问答