partitioning.years

Zaman damgaları ve tarihler için verileri yıllara bölmek amacıyla bir dönüşüm.

Uyarı

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

Sözdizimi

from pyspark.sql.functions import partitioning

partitioning.years(col)

Parametreler

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

Örnekler

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