clusterBy (DataFrameWriter)

クエリのパフォーマンスを最適化するために、指定された列によってデータを収集します。

構文

clusterBy(*cols)

パラメーター

パラメーター	Type	説明
*cols	文字列またはリスト	クラスター化する列の名前。

戻り値

DataFrameWriter

例

クラスタリングを使用してDataFrameをParquetファイルに書き込みます。

Python

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)