Freigeben über


text (DataFrameWriter)

Speichert den Inhalt der DataFrame in einer Textdatei am angegebenen Pfad. Textdateien werden als UTF-8 codiert.

Syntax

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

Parameter

Parameter Typ Beschreibung
path str Der Pfad in einem hadoop-unterstützten Dateisystem.
compression str, optional Der zu verwendende Komprimierungscodec.
lineSep str, optional Das zu verwendende Zeilentrennzeichen.

Rückkehr

Nichts

Hinweise

Die DataFrame Zeichenfolge darf nur eine Spalte aufweisen. Jede Zeile wird zu einer neuen Zeile in der Ausgabedatei.

Beispiele

Schreiben Sie einen DataFrame in eine Textdatei, und lesen Sie ihn zurück.

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|
    # +---------+