dias

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

atenção

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

Sintaxe

Python

from pyspark.sql import functions as dbf

dbf.days(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.

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 dias.

Exemplos

Python

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

nota

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