Дни

Функция преобразования секций: преобразование меток времени и дат для секционирования данных в дни. Поддерживает Spark Connect.

Предупреждение

Не рекомендуется использовать в версии 4.0.0. Вместо этого используйте partitioning.days.

Синтаксис

from pyspark.sql import functions as dbf

dbf.days(col=<col>)

Параметры

Параметр	Тип	Description
col	pyspark.sql.Column или str	Целевая дата или столбец метки времени для работы.

Возвраты

pyspark.sql.Column: данные, секционированные по дням.

Примеры

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

Замечание

Эту функцию можно использовать только в сочетании с методом partitionedBy DataFrameWriterV2.