Jegyzet
Az oldalhoz való hozzáférés engedélyezést igényel. Próbálhatod be jelentkezni vagy könyvtárat váltani.
Az oldalhoz való hozzáférés engedélyezést igényel. Megpróbálhatod a könyvtár váltását.
A megadott egységekben lévő időbélyegek különbségét kapja meg a törtrész csonkolásával.
Szemantika
from pyspark.databricks.sql import functions as dbf
dbf.timestamp_diff(unit=<unit>, start=<start>, end=<end>)
Paraméterek
| Paraméter | Típus | Description |
|---|---|---|
unit |
literal string |
Ez a megadott időbélyegek közötti különbség mértékegységét jelzi. A támogatott lehetőségek a következők (a kis- és nagybetűk nem érzékenyek): "ÉV", "NEGYEDÉV", "HÓNAP", "HÉT", "NAP", "ÓRA", "PERC", "SECOND", "EZREDMÁSODPERC" és "MIKROSECOND". |
start |
pyspark.sql.Column vagy str |
Egy időbélyeg, amelyből a kifejezés kivonja a következőt endTimestamp: . |
end |
pyspark.sql.Column vagy str |
Egy időbélyeg, amelyből a kifejezés kivonja azokat startTimestamp. |
Visszatérítések
pyspark.sql.Column: az időbélyegek közötti különbség.
Példák
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()