Часов

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

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

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

Синтаксис

from pyspark.sql import functions as dbf

dbf.hours(col=<col>)

Параметры

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

Возвраты

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

Примеры

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

Замечание

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