Anmerkung
Der Zugriff auf diese Seite erfordert eine Genehmigung. Du kannst versuchen, dich anzumelden oder die Verzeichnisse zu wechseln.
Der Zugriff auf diese Seite erfordert eine Genehmigung. Du kannst versuchen , die Verzeichnisse zu wechseln.
Konvertiert den Zeitstempel ohne Zeitzone sourceTs von der sourceTz Zeitzone in targetTz.
Die entsprechende Databricks SQL-Funktion finden Sie unter convert_timezone Funktion.
Syntax
from pyspark.databricks.sql import functions as dbf
dbf.convert_timezone(sourceTz=<sourceTz>, targetTz=<targetTz>, sourceTs=<sourceTs>)
Die Parameter
| Parameter | Typ | Description |
|---|---|---|
sourceTz |
pyspark.sql.Column, optional |
Die Zeitzone für den Eingabezeitstempel. Wenn sie verpasst wird, wird die aktuelle Zeitzone der Sitzung als Quellzeitzone verwendet. |
targetTz |
pyspark.sql.Column |
Die Zeitzone, in die der Eingabezeitstempel konvertiert werden soll. |
sourceTs |
pyspark.sql.Column oder str |
Ein Zeitstempel ohne Zeitzone. |
Rückkehr
pyspark.sql.Column: Eine neue Spalte, die einen Zeitstempel für konvertierte Zeitzone enthält.
Examples
spark.conf.set("spark.sql.session.timeZone", "America/Los_Angeles")
from pyspark.databricks.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")