擅长:python、mysql、java
<p>我找到了一个解决方案:</p>
<pre><code>from pyspark.sql.types import TimestampType
extra_column_df = roundtrip_df.select(roundtrip_df.Day, roundtrip_df.Date).withColumn('new_date', roundtrip_df.Date / 1000000000)
roundtrip_timestamp_df = extra_column_df.select(extra_column_df.Day, extra_column_df.new_date.cast(TimestampType()).alias('Date')
</code></pre>
<p>输出:</p>
^{pr2}$
<p>作为一个附加的bug或特性,这似乎将所有日期转换为UTC,包括DST感知。在</p>