particionamento.anos

Uma transformação para registros de data e hora e datas para particionar dados em anos.

nota

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

Sintaxe

Python

from pyspark.sql.functions import partitioning

partitioning.years(col)

Parâmetros

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

Exemplos

Python

from pyspark.sql.functions import partitioning
df.writeTo("catalog.db.table").partitionedBy(
    partitioning.years("ts")
).createOrReplace()