heures
Fonction de transformation de partition : Une transformation pour les Timestamp afin de partitionner les données en heures. Prend en charge Spark Connect.
attention
Obsolète dans la version 4.0.0. Utilisez partitioning.hours au lieu de.
Syntaxe
Python
from pyspark.sql import functions as dbf
dbf.hours(col=<col>)
parameter
parameter | Type | Description |
|---|---|---|
|
| Ciblez la colonne de date ou de Timestamp sur laquelle travailler. |
Renvoie
pyspark.sql.Column: Données partitionnées par heures.
Exemples
Python
df.writeTo("catalog.db.table").partitionedBy(
hours("ts")
).createOrReplace()
remarque
Cette fonction peut être utilisée uniquement en combinaison avec la méthode partitionedBy du DataFrameWriterV2.