pyspark.sql.functions.months

pyspark.sql.functions.months(col: ColumnOrName) → pyspark.sql.column.Column

Partition transform function: A transform for timestamps and dates to partition data into months.

New in version 3.1.0.

Notes

This function can be used only in combination with partitionedBy() method of the DataFrameWriterV2.

Examples

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

pyspark.sql.functions.years pyspark.sql.functions.days