分数部分を切り捨てることで、指定した単位のタイムスタンプの差を取得します。
構文
from pyspark.databricks.sql import functions as dbf
dbf.timestamp_diff(unit=<unit>, start=<start>, end=<end>)
パラメーター
| パラメーター | タイプ | Description |
|---|---|---|
unit |
literal string |
これは、指定されたタイムスタンプ間の差の単位を示します。 サポートされているオプションは (大文字と小文字を区別しません): "YEAR"、"QUARTER"、"MONTH"、"WEEK"、"DAY"、"HOUR"、"MINUTE"、"SECOND"、"MILLISECOND"、"MICROSECOND" です。 |
start |
pyspark.sql.Column または str |
式が endTimestampから減算するタイムスタンプ。 |
end |
pyspark.sql.Column または str |
式が startTimestampを減算するタイムスタンプ。 |
返品ポリシー
pyspark.sql.Column: タイムスタンプの違い。
例示
import datetime
from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame(
[(datetime.datetime(2016, 3, 11, 9, 0, 7), datetime.datetime(2024, 4, 2, 9, 0, 7))],
['ts1', 'ts2'])
df.select('*', dbf.timestamp_diff('year', 'ts1', 'ts2')).show()
df.select('*', dbf.timestamp_diff('WEEK', 'ts1', 'ts2')).show()
df.select('*', dbf.timestamp_diff('day', df.ts2, df.ts1)).show()