kbelík

Funkce transformace oddílu: Transformace pro libovolný typ, který se dělí hodnotou hash vstupního sloupce. Podporuje Spark Connect.

Výstraha

Zastaralé ve verzi 4.0.0. Místo toho použijte partitioning.bucket.

Syntaxe

from pyspark.sql import functions as dbf

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

Parametry

Parameter	Typ	Description
numBuckets	pyspark.sql.Column nebo int	Počet kbelíků.
col	pyspark.sql.Column nebo str	Cílové datum nebo sloupec časového razítka, na kterém chcete pracovat.

Návraty

pyspark.sql.Column: Data rozdělená podle zadaných sloupců.

Examples

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

Poznámka:

Tuto funkci lze použít pouze v kombinaci s partitionedBy metodou DataFrameWriterV2.