convert_timezone

Convierte la marca de tiempo sin zona sourceTs horaria de la sourceTz zona horaria a targetTz.

Para obtener la función SQL de Databricks correspondiente, consulte convert_timezone function.

Syntax

from pyspark.sql import functions as dbf

dbf.convert_timezone(sourceTz=<sourceTz>, targetTz=<targetTz>, sourceTs=<sourceTs>)

Parámetros

Parámetro	Tipo	Description
sourceTz	pyspark.sql.Column, optional	Zona horaria de la marca de tiempo de entrada. Si se pierde, la zona horaria de sesión actual se usa como zona horaria de origen.
targetTz	pyspark.sql.Column	Zona horaria a la que se debe convertir la marca de tiempo de entrada.
sourceTs	pyspark.sql.Column o str	Marca de tiempo sin zona horaria.

Devoluciones

pyspark.sql.Column: una nueva columna que contiene una marca de tiempo para la zona horaria convertida.

Examples

spark.conf.set("spark.sql.session.timeZone", "America/Los_Angeles")

from pyspark.sql import functions as dbf
df = spark.createDataFrame([('2015-04-08 00:00:00',)], ['ts'])
df.select(
'*',
dbf.convert_timezone(None, dbf.lit('Asia/Hong_Kong'), 'ts')
).show()
df = spark.createDataFrame([('2015-04-08 15:00:00',)], ['ts'])
df.select(
'*',
dbf.convert_timezone(dbf.lit('Asia/Hong_Kong'), dbf.lit('America/Los_Angeles'), df.ts)
).show()
spark.conf.unset("spark.sql.session.timeZone")