タイムゾーン変換

タイムゾーンなしのタイムスタンプsourceTs sourceTzタイムゾーンからtargetTzに変換します。

対応する Databricks SQL 関数については、 convert_timezone関数を参照してください。

構文

Python

from pyspark.sql import functions as dbf

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

パラメーター

パラメーター	Type	説明
sourceTz	pyspark.sql.Column, optional	入力タイムスタンプのタイムゾーン。指定しない場合は、現在のセッションのタイムゾーンがソース タイムゾーンとして使用されます。
targetTz	pyspark.sql.Column	入力タイムスタンプを変換するタイムゾーン。
sourceTs	pyspark.sql.Column または str	タイムゾーンのないタイムスタンプ。

パラメーター	Type	説明
sourceTz	pyspark.sql.Column, optional	入力タイムスタンプのタイムゾーン。指定しない場合は、現在のセッションのタイムゾーンがソース タイムゾーンとして使用されます。
targetTz	pyspark.sql.Column	入力タイムスタンプを変換するタイムゾーン。
sourceTs	pyspark.sql.Column または str	タイムゾーンのないタイムスタンプ。

戻り値

pyspark.sql.Column: 変換されたタイムゾーンのタイムスタンプを含む新しい列。

例

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