convert_timezone

Преобразует метку времени без часового пояса из часового targetTzпояса sourceTssourceTz в .

Для соответствующей функции Databricks SQL смотрите функцию convert_timezone.

Синтаксис

from pyspark.databricks.sql import functions as dbf

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

Параметры

Параметр	Тип	Description
sourceTz	pyspark.sql.Column, optional	Часовой пояс входной метки времени. Если он отсутствует, текущий часовой пояс сеанса используется в качестве исходного часового пояса.
targetTz	pyspark.sql.Column	Часовой пояс, в который следует преобразовать метку времени ввода.
sourceTs	pyspark.sql.Column или str	Метка времени без часового пояса.

Возвраты

pyspark.sql.Column: новый столбец, содержащий метку времени для преобразованного часового пояса.

Примеры

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