try_make_timestamp_ltz
年、月、日、時間、分、秒、タイムゾーン フィールドから、ローカル タイム ゾーンで現在のタイムスタンプを作成します。関数は無効な入力に対して NULL を返します。
構文
Python
from pyspark.databricks.sql import functions as dbf
dbf.try_make_timestamp_ltz(years=<years>, months=<months>, days=<days>, hours=<hours>, mins=<mins>, secs=<secs>, timezone=<timezone>)
パラメーター
パラメーター | Type | 説明 |
|---|---|---|
|
| 表現する年(1~9999) |
|
| 1(1月)から12(12月)までの月を表します |
|
| 1から31までの月日を表す |
|
| 0から23までの時間を表す |
|
| 0から59までの分を表す |
|
| 0 から 60 までの秒数とその小数部を表します。値は 13 のような整数、または 13.123 のような分数のいずれかになります。sec 引数が 60 に等しい場合、秒フィールドは 0 に設定され、最終タイムスタンプに 1 分が追加されます。 |
|
| タイムゾーン識別子。たとえば、CET、UTC など。 |
戻り値
pyspark.sql.Column: 現在のタイムスタンプを含む新しい列。エラーの場合は NULL になります。
例
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.try_make_timestamp_ltz('year', 'month', df.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.try_make_timestamp_ltz('year', 'month', df.day, df.hour, df.min, df.sec)
).show(truncate=False)
df = spark.createDataFrame([[2014, 13, 28, 6, 30, 45.887, 'CET']],
['year', 'month', 'day', 'hour', 'min', 'sec', 'tz'])
df.select(
dbf.try_make_timestamp_ltz('year', 'month', df.day, df.hour, df.min, df.sec)
).show(truncate=False)
spark.conf.unset("spark.sql.session.timeZone")