Megosztás:


timestamp_diff

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()