Yıl

Bölüm dönüştürme işlevi: Verileri yıllara bölmek için zaman damgaları ve tarihler için bir dönüşüm. Spark Connect'i destekler.

Uyarı

4.0.0'da kullanım dışı bırakıldı. Bunun yerine partitioning.years kullanın.

Sözdizimi

from pyspark.sql import functions as dbf

dbf.years(col=<col>)

Parametreler

Parametre	Türü	Description
col	pyspark.sql.Column veya str	Üzerinde çalışacak tarih veya zaman damgası sütununu hedefle.

İade

pyspark.sql.Column: Yıllara göre bölümlenmiş veriler.

Örnekler

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

Uyarı

Bu işlev yalnızca DataFrameWriterV2 yöntemiyle partitionedBy birlikte kullanılabilir.