我正在尝试获取spark-scala的本地时间,但它返回UTC。
我使用java.time.LocalDateTime来获取当前的时间戳。但它又回到了UTC标准。
java.sql.Timestamp.valueOf(DateTimeFormatter.ofPattern("YYYY-MM-dd HH:mm:ss.SSSSSS").format(LocalDateTime.now))LocalDateTime在spark shell中返回本地时间,但在我的代码中它提供了协调世界时的标准。
val time: LocalDateTime = LocalDateTime.now如何获取当前时间?
当前输出为UTC。我需要当地时间。我要换个区域。
发布于 2020-10-03 02:59:12
我所知道的最好的方法是根据你的时区使用GMT偏移量。获取GMT偏移量并进行替换。在本例中,我的GMT偏移量是-5。如果有帮助,请告诉我。如果他的解决了问题,请告诉我。
df=spark.sql("select from_utc_timestamp(current_timestamp(),'GMT-5') AS your_local_datetime")
df.show(truncate=False)发布于 2019-09-28 14:02:11
在org.apache.spark.sql.fuctions中使用current_timestamp(),这提供了本地时间。
https://stackoverflow.com/questions/58143743
复制相似问题