Как получить текущее местное время или системное время в кадре данных spark-scala?

Question

Я пытаюсь получить местное время в spark-scala, но оно возвращает UTC.

Я использую java.time.LocalDateTime, чтобы получить текущую метку времени.Но он возвращает стандарт UTC.

java.sql.Timestamp.valueOf(DateTimeFormatter.ofPattern("YYYY-MM-dd HH:mm:ss.SSSSSS").format(LocalDateTime.now))

LocalDateTime возвращает местное время в спарк-оболочке, но в моем коде он дает стандарт UTC.

val time: LocalDateTime = LocalDateTime.now

Как получить текущийвремя?

Токовый выход по UTC.Мне нужно местное время.Мне нужно изменить зону.

Answer 1

Используйте current_timestamp() в org.apache.spark.sql.fuctions, это дает местное время.