kova

Bölüm dönüştürme işlevi: Giriş sütununun karmasıyla bölümleyen herhangi bir tür için dönüştürme. Spark Connect'i destekler.

Uyarı

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

Sözdizimi

from pyspark.sql import functions as dbf

dbf.bucket(numBuckets=<numBuckets>, col=<col>)

Parametreler

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

İade

pyspark.sql.Column: Verilen sütunlar tarafından bölümlenmiş veriler.

Örnekler

df.writeTo("catalog.db.table").partitionedBy(
    bucket(42, "ts")
).createOrReplace()

Uyarı

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