années

Fonction de transformation de partition : transformation pour les horodatages et les dates pour partitionner les données en années. Prend en charge Spark Connect.

Avertissement

Déconseillé dans la version 4.0.0. Utilisez partitioning.years à la place.

Syntaxe

from pyspark.databricks.sql import functions as dbf

dbf.years(col=<col>)

Paramètres

Paramètre	Type	Descriptif
col	pyspark.sql.Column ou str	Date cible ou colonne d’horodatage sur laquelle travailler.

Retours

pyspark.sql.Column: données partitionnés par années.

Examples

df.writeTo("catalog.db.table").partitionedBy(
    years("ts")
).createOrReplace()

Note

Cette fonction peut être utilisée uniquement en combinaison avec la partitionedBy méthode de DataFrameWriterV2.