将 CURRENT_TIMESTAMP() 时间从 UTC 转换为 ET

Question

我正在使用Spark SQL的CURRENT_TIMESTAMP（）时间函数更新我的数据帧字段创建日期。返回的值采用 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")

这也必须处理夏令时。