convert_timezone

Convertit le Timestamp sans fuseau horaire sourceTs du fuseau horaire sourceTz vers targetTz.

Pour la fonction Databricks SQL correspondante, consultez la fonctionconvert_timezone.

Syntaxe

Python

from pyspark.sql import functions as dbf

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

parameter

parameter	Type	Description
sourceTz	pyspark.sql.Column, optional	Le fuseau horaire pour le Timestamp d'entrée. S'il est manqué, le fuseau horaire de la session actuelle est utilisé comme fuseau horaire source.
targetTz	pyspark.sql.Column	Le fuseau horaire vers lequel l'input Timestamp doit être converti.
sourceTs	pyspark.sql.Column OU str	Un Timestamp sans fuseau horaire.

parameter	Type	Description
sourceTz	pyspark.sql.Column, optional	Le fuseau horaire pour le Timestamp d'entrée. S'il est manqué, le fuseau horaire de la session actuelle est utilisé comme fuseau horaire source.
targetTz	pyspark.sql.Column	Le fuseau horaire vers lequel l'input Timestamp doit être converti.
sourceTs	pyspark.sql.Column OU str	Un Timestamp sans fuseau horaire.

Renvoie

pyspark.sql.Column: Une nouvelle colonne qui contient un timestamp pour le fuseau horaire converti.

Exemples

Python

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

Python

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