time_diff

Belirtilen birimlerle ölçülen iki kez arasındaki farkı döndürür.

Sözdizimi

from pyspark.sql import functions as dbf

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

Parametreler

Parametre Türü Description
unit pyspark.sql.Column veya str Zamanı kesecek birim. Desteklenen birimler şunlardır: "HOUR", "MINUTE", "SECOND", "MILISECOND" ve "MICROSECOND". Birim büyük/küçük harfe duyarlı değildir.
start pyspark.sql.Column veya str Başlangıç zamanı.
end pyspark.sql.Column veya str Bitiş saati.

İade

pyspark.sql.Column: Belirtilen birimlerde iki kez arasındaki fark.

Örnekler

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