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.sql import functions as dbf

dbf.years(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 anos.

Exemplos

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.