タイムスタンプを作成するltz

年、月、日、時間、分、秒、タイムゾーン フィールドから、ローカル タイム ゾーンで現在のタイムスタンプを作成します。構成spark.sql.ansi.enabledが false の場合、関数は無効な入力に対して NULL を返します。それ以外の場合は、代わりにエラーがスローされます。

構文

Python

from pyspark.databricks.sql import functions as dbf

dbf.make_timestamp_ltz(years=<years>, months=<months>, days=<days>, hours=<hours>, mins=<mins>, secs=<secs>, timezone=<timezone>)

パラメーター

パラメーター	Type	説明
years	pyspark.sql.Column または str	表現する年（1～9999）
months	pyspark.sql.Column または str	1（1月）から12（12月）までの月を表します
days	pyspark.sql.Column または str	1から31までの月日を表す
hours	pyspark.sql.Column または str	0から23までの時間を表す
mins	pyspark.sql.Column または str	0から59までの分を表す
secs	pyspark.sql.Column または str	0 から 60 までの秒数とその小数部を表します。値は 13 のような整数、または 13.123 のような分数のいずれかになります。sec 引数が 60 に等しい場合、秒フィールドは 0 に設定され、最終タイムスタンプに 1 分が追加されます。
timezone	pyspark.sql.Column または str, optional	タイムゾーン識別子。たとえば、CET、UTC など。

戻り値

pyspark.sql.Column: 現在のタイムスタンプを含む新しい列。

例

Python

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

Python

from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame([[2014, 12, 28, 6, 30, 45.887, 'CET']],
['year', 'month', 'day', 'hour', 'min', 'sec', 'tz'])
df.select(
dbf.make_timestamp_ltz(df.year, df.month, 'day', df.hour, df.min, df.sec, 'tz')
).show(truncate=False)
df = spark.createDataFrame([[2014, 12, 28, 6, 30, 45.887, 'CET']],
['year', 'month', 'day', 'hour', 'min', 'sec', 'tz'])
df.select(
dbf.make_timestamp_ltz(df.year, df.month, 'day', df.hour, df.min, df.sec)
).show(truncate=False)
spark.conf.unset("spark.sql.session.timeZone")