Вопрос похож на проблему: Измените метку времени на формат UTC в Pyspark
По сути, это преобразование формата строки метки времени ISO8601 со смещением в строку метки времени UTC (2017-08-01T14:30:00+05:30
-> 2017-08-01T09:00:00+00:00
) с использованием scala.
Я как бы новичок в scala / java, я проверил библиотеку искр, которую у них нет возможности преобразовать, не зная часовой пояс, который у меня нет представления о часовом поясе, если (я не разбираю его уродливым способом или использую java / scala lib? ) Может кто поможет?
ОБНОВЛЕНИЕ: лучший способ сделать это: настроить сеанс часового пояса в Spark и использовать df.cast(DataTypes.TimestampType)
для сдвига часового пояса