différence_temps

Renvoie la différence entre deux temps, mesurée en unités spécifiées.

Syntaxe

Python

from pyspark.sql import functions as dbf

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

parameter

parameter	Type	Description
unit	pyspark.sql.Column OU str	L'unité pour tronquer l'heure. Les unités prises en charge sont : "heure", "minute", "seconde", "milliseconde" et "microseconde". L'unité ne tient pas compte de la casse.
start	pyspark.sql.Column OU str	Une heure de début.
end	pyspark.sql.Column OU str	Une heure de fin.

parameter	Type	Description
unit	pyspark.sql.Column OU str	L'unité pour tronquer l'heure. Les unités prises en charge sont : "heure", "minute", "seconde", "milliseconde" et "microseconde". L'unité ne tient pas compte de la casse.
start	pyspark.sql.Column OU str	Une heure de début.
end	pyspark.sql.Column OU str	Une heure de fin.

Renvoie

pyspark.sql.Column: La différence entre deux instants, dans les unités spécifiées.

Exemples

Python

from pyspark.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()