Скажем, у меня есть фрейм данных с именем эпохи столбцов, которое составляет секунды от времени эпохи, и я хотел преобразовать его во время UTC. Как это сделать в Pyspark?
Я не хочу кодировать «GMT-7» и хочу убедиться, что я использую правильное смещение для времени, GMT-7 или GMT-8, исходя из летнего времени. Я использую Spark 2.1
myDF = myDF.withColumn("epoch_tmst",(myDF.epoch.cast(dataType=TimestampType()))
myDF = myDF.withColumn("epoch_tmst_utc",to_utc_timestamp(myDF.epoch_tmst,"GMT-7"))