Примечание.
Для доступа к этой странице требуется авторизация. Вы можете попробовать войти или изменить каталоги.
Для доступа к этой странице требуется авторизация. Вы можете попробовать изменить каталоги.
Функция преобразования секций: преобразование меток времени и дат для секционирования данных в годы. Поддерживает Spark Connect.
Предупреждение
Не рекомендуется использовать в версии 4.0.0. Вместо этого используйте partitioning.years.
Синтаксис
from pyspark.sql import functions as dbf
dbf.years(col=<col>)
Параметры
| Параметр | Тип | Description |
|---|---|---|
col |
pyspark.sql.Column или str |
Целевая дата или столбец метки времени для работы. |
Возвраты
pyspark.sql.Column: данные секционируются по годам.
Примеры
df.writeTo("catalog.db.table").partitionedBy(
years("ts")
).createOrReplace()
Замечание
Эту функцию можно использовать только в сочетании с методом partitionedBy DataFrameWriterV2.