time_trunc

Возвращает time усеченный к элементу unit.

Синтаксис

from pyspark.databricks.sql import functions as dbf

dbf.time_trunc(unit=<unit>, time=<time>)

Параметры

Параметр	Тип	Description
unit	pyspark.sql.Column или str	Единица для усечения времени. Поддерживаемые единицы: HOUR, MINUTE, SECOND, MILLISECOND и MICROSECOND. Единица не учитывает регистр.
time	pyspark.sql.Column или str	Время усечения.

Возвраты

pyspark.sql.Column: время усечено до указанной единицы.

Примеры

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