Notitie
Voor toegang tot deze pagina is autorisatie vereist. U kunt proberen u aan te melden of de directory te wijzigen.
Voor toegang tot deze pagina is autorisatie vereist. U kunt proberen de mappen te wijzigen.
Hiermee worden de gegevens geclusterd op basis van de opgegeven kolommen om de queryprestaties te optimaliseren.
Syntaxis
clusterBy(*cols)
Parameters
| Kenmerk | Typ | Beschrijving |
|---|---|---|
*cols |
str of list | Namen van de kolommen die moeten worden geclusterd op. |
Retouren
DataFrameWriter
Examples
Schrijf een DataFrame naar een Parquet-bestand met clustering.
import tempfile
with tempfile.TemporaryDirectory(prefix="clusterBy") as d:
spark.createDataFrame(
[{"age": 100, "name": "Alice"}, {"age": 120, "name": "Ruifeng Zheng"}]
).write.clusterBy("name").mode("overwrite").format("parquet").save(d)