time_diff

返回以指定单位度量的两次之差。

Syntax

from pyspark.databricks.sql import functions as dbf

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

参数

参数	类型	Description
unit	pyspark.sql.Column 或 str	要截断其时间的单位。 支持的单位包括：“HOUR”、“MINUTE”、“SECOND”、“毫秒”和“MICROSECOND”。 该单元不区分大小写。
start	pyspark.sql.Column 或 str	开始时间。
end	pyspark.sql.Column 或 str	结束时间。

退货

pyspark.sql.Column：指定单位中的两次之差。

例子

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