tekst (DataFrameWriter)

Slaat de inhoud van het DataFrame bestand op in een tekstbestand op het opgegeven pad. Tekstbestanden worden gecodeerd als UTF-8.

Syntaxis

text(path, compression=None, lineSep=None)

Parameterwaarden

Kenmerk Typ Beschrijving
path str Het pad in een door Hadoop ondersteund bestandssysteem.
compression str, optioneel De compressiecodec die moet worden gebruikt.
lineSep str, optioneel Het regelscheidingsteken dat moet worden gebruikt.

Retouren

Geen

Aantekeningen

De DataFrame kolom mag slechts één kolom van het tekenreekstype hebben. Elke rij wordt een nieuwe regel in het uitvoerbestand.

Examples

Schrijf een DataFrame naar een tekstbestand en lees het terug.

import tempfile
with tempfile.TemporaryDirectory(prefix="text") as d:
    df = spark.createDataFrame([("a",), ("b",), ("c",)], schema=["alphabets"])
    df.write.mode("overwrite").text(d)

    spark.read.schema(df.schema).format("text").load(d).sort("alphabets").show()
    # +---------+
    # |alphabets|
    # +---------+
    # |        a|
    # |        b|
    # |        c|
    # +---------+
  • Last updated on