apache-spark-sql - 将 CURRENT_TIMESTAMP() 时间从 UTC 转换为 ET

Question

我正在使用Spark SQL 的CURRENT_TIMESTAMP()时间函数更新我的数据框字段Create Date 。返回的值采用 UTC 时区。

我想要东部时间的值（处理夏令时）。当我将 SQL 查询传递给sqlContext.sql时，我想进行时区转换。我怎样才能做到这一点？

谢谢。

Answer 1

您可以使用 from_utc_timestamp 功能来执行此操作。

import org.apache.spark.sql.types.TimestampType

// This sample syntax. You can replace your value at literal location.
from_utc_timestamp(lit("2018-12-01 00:00:00").cast(TimestampType), "EST5EDT")

这也必须处理夏令时。