Megosztás:


time_diff

A két alkalommal megadott egységekben mért különbséget adja vissza.

Szemantika

from pyspark.databricks.sql import functions as dbf

dbf.time_diff(unit=<unit>, start=<start>, end=<end>)

Paraméterek

Paraméter Típus Description
unit pyspark.sql.Column vagy str Az egység, amely lerövidíti az időt. A támogatott egységek a következők: "HOUR", "MINUTE", "SECOND", "EZREDMÁSODPERC" és "MICROSECOND". Az egység nem érzékeny a kis- és nagybetűkre.
start pyspark.sql.Column vagy str Kezdési időpont.
end pyspark.sql.Column vagy str Egy befejezési időpont.

Visszatérítések

pyspark.sql.Column: A két alkalom közötti különbség a megadott egységekben.

Példák

from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame(
[("HOUR", "13:08:15", "21:30:28")], ['unit', 'start', 'end']).withColumn("start",
dbf.col("start").cast("time")).withColumn("end", dbf.col("end").cast("time"))
df.select('*', dbf.time_diff('unit', 'start', 'end')).show()