convert_timezone

Převede časové razítko bez časového pásma z časového pásma sourceTssourceTz na targetTz.

Odpovídající funkci SQL Databricks vizte funkceconvert_timezone.

Syntaxe

from pyspark.sql import functions as dbf

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

Parametry

Parameter	Typ	Description
sourceTz	pyspark.sql.Column, optional	Časové pásmo pro vstupní časové razítko. Pokud je vynecháno, použije se aktuální časové pásmo relace jako zdrojové časové pásmo.
targetTz	pyspark.sql.Column	Časové pásmo, na které má být převedeno vstupní časové razítko.
sourceTs	pyspark.sql.Column nebo str	Časové razítko bez časového pásma.

Návraty

pyspark.sql.Column: Nový sloupec, který obsahuje časové razítko pro převedené časové pásmo.

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")