タイムスタンプ追加
小数部分を切り捨てて、指定された単位でタイムスタンプの差を取得します。
構文
Python
from pyspark.databricks.sql import functions as dbf
dbf.timestamp_add(unit=<unit>, quantity=<quantity>, ts=<ts>)
パラメーター
パラメーター | Type | 説明 |
|---|---|---|
|
| これは、指定されたタイムスタンプ間の差の単位を示します。サポートされているオプションは (大文字と小文字は区別されません)、「YEAR」、「QUARTER」、「MONTH」、「WEEK」、「DAY」、「HOUR」、「MINUTE」、「SECOND」、「MILLISECOND」、「MICROSECOND」です。 |
|
| 追加する時間単位の数。 |
|
| 追加するタイムスタンプ。 |
戻り値
pyspark.sql.Column: タイムスタンプの差。
例
Python
import datetime
from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame(
[(datetime.datetime(2016, 3, 11, 9, 0, 7), 2),
(datetime.datetime(2024, 4, 2, 9, 0, 7), 3)], ['ts', 'quantity'])
df.select('*', dbf.timestamp_add('year', 'quantity', 'ts')).show()
df.select('*', dbf.timestamp_add('WEEK', dbf.lit(5), df.ts)).show()
df.select('*', dbf.timestamp_add('day', dbf.lit(-5), 'ts')).show()