convert_timezone

Konwertuje znacznik czasu bez strefy czasowej ze strefy sourceTs czasowej sourceTz na targetTz.

Aby uzyskać odpowiednią funkcję SQL usługi Databricks, zobacz convert_timezone funkcja.

Składnia

from pyspark.databricks.sql import functions as dbf

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

Parametry

Parameter	Typ	Description
sourceTz	pyspark.sql.Column, optional	Strefa czasowa wejściowego znacznika czasu. Jeśli zostanie pominięta, bieżąca strefa czasowa sesji jest używana jako źródłowa strefa czasowa.
targetTz	pyspark.sql.Column	Strefa czasowa, do której ma zostać przekonwertowana sygnatura czasowa danych wejściowych.
sourceTs	pyspark.sql.Column lub str	Znacznik czasu bez strefy czasowej.

Zwraca

pyspark.sql.Column: Nowa kolumna zawierająca znacznik czasu dla przekonwertowanej strefy czasowej.

Przykłady

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