pyspark.sql.functions.days¶
-
pyspark.sql.functions.
days
(col: ColumnOrName) → pyspark.sql.column.Column¶ Partition transform function: A transform for timestamps and dates to partition data into days.
Notes
This function can be used only in combination with
partitionedBy()
method of the DataFrameWriterV2.Examples
>>> df.writeTo("catalog.db.table").partitionedBy( ... days("ts") ... ).createOrReplace()