ans
Fonction de transformation de partition : une transformation pour les Timestamp et les dates afin de partitionner les données en années. Prend en charge Spark Connect.
attention
Obsolète dans la version 4.0.0. Utilisez partitioning.years au lieu de.
Syntaxe
Python
from pyspark.sql import functions as dbf
dbf.years(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 année.
Exemples
Python
df.writeTo("catalog.db.table").partitionedBy(
years("ts")
).createOrReplace()
remarque
Cette fonction peut être utilisée uniquement en combinaison avec la méthode partitionedBy du DataFrameWriterV2.