time_trunc
Retourne time tronqué à unit.
Syntaxe
Python
from pyspark.sql import functions as dbf
dbf.time_trunc(unit=<unit>, time=<time>)
parameter
parameter | Type | Description |
|---|---|---|
|
| 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. |
|
| Le moment de tronquer. |
Renvoie
pyspark.sql.Column: Un temps tronqué à l'unité spécifiée.
Exemples
Python
from pyspark.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()