clusterBy(DataFrameWriter)

지정된 열별로 데이터를 클러스터하여 쿼리 성능을 최적화합니다.

문법

clusterBy(*cols)

매개 변수

매개 변수	유형	설명
*cols	str 또는 list	클러스터할 열의 이름입니다.

Returns

DataFrameWriter

예제

클러스터링을 사용하여 Parquet 파일에 DataFrame을 작성합니다.

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)