horas

Função de transformação de partição: Uma transformação para registros de data e hora que permite particionar os dados em horas. Compatível com Spark Connect.

atenção

Obsoleto na versão 4.0.0. Use partitioning.hours em vez disso.

Sintaxe

Python

from pyspark.databricks.sql import functions as dbf

dbf.hours(col=<col>)

Parâmetros

Parâmetro	Tipo	Descrição
col	pyspark.sql.Column ou str	Coluna de data ou hora de destino na qual trabalhar.

Devoluções

pyspark.sql.ColumnDados divididos por horas.

Exemplos

Python

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

nota

Esta função só pode ser usada em combinação com o método partitionedBy do DataFrameWriterV2.