partitioning.days

Une transformation pour les Timestamp et les dates afin de partitionner les données en jours.

remarque

Cette fonction ne peut être utilisée qu'en combinaison avec la méthode DataFrameWriterV2.partitionedBy.

Syntaxe

Python

from pyspark.sql.functions import partitioning

partitioning.days(col)

parameter

parameter	Type	Description
col	pyspark.sql.Column ou str	Ciblez la colonne de date ou de Timestamp sur laquelle travailler.

parameter	Type	Description
col	pyspark.sql.Column ou str	Ciblez la colonne de date ou de Timestamp sur laquelle travailler.

Exemples

Python

from pyspark.sql.functions import partitioning
df.writeTo("catalog.db.table").partitionedBy(
    partitioning.days("ts")
).createOrReplace()