anos

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

atenção

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

Sintaxe

Python
from pyspark.databricks.sql import functions as dbf

dbf.years(col=<col>)

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

pyspark.sql.ColumnDados divididos por anos.

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

nota

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