parquet (DataFrameWriter)

öğesinin DataFrame içeriğini belirtilen yola Parquet biçiminde kaydeder.

Sözdizimi

parquet(path, mode=None, partitionBy=None, compression=None)

Parametreler

Parametre	Türü	Açıklama
path	str	Hadoop tarafından desteklenen herhangi bir dosya sistemindeki yol.
mode	str, isteğe bağlı	Veriler zaten mevcut olduğunda davranış. Kabul edilen değerler , 'append', 'overwrite've 'ignore' veya 'error' (varsayılan) değerleridir'errorifexists'.
partitionBy	str veya list, isteğe bağlı	Bölümleme sütunlarının adları.
compression	str, isteğe bağlı	Kullanılacak sıkıştırma codec bileşeni.

İadeler

Hiçbiri

Örnekler

Bir Parquet dosyasına DataFrame yazın ve yeniden okuyun.

import tempfile
with tempfile.TemporaryDirectory(prefix="parquet") as d:
    spark.createDataFrame(
        [{"age": 100, "name": "Alice"}]
    ).write.parquet(d, mode="overwrite")

    spark.read.format("parquet").load(d).show()
    # +---+------------+
    # |age|        name|
    # +---+------------+
    # |100|Alice|
    # +---+------------+