Condividi tramite


text (DataFrameWriter)

Salva il contenuto di in un file di DataFrame testo nel percorso specificato. I file di testo vengono codificati come UTF-8.

Sintassi

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

Parametri

Parametro Tipo Descrizione
path str Percorso in qualsiasi file system supportato da Hadoop.
compression str, facoltativo Codec di compressione da usare.
lineSep str, facoltativo Separatore di riga da utilizzare.

Restituzioni

Nessuno

Note

Deve DataFrame avere una sola colonna di tipo stringa. Ogni riga diventa una nuova riga nel file di output.

Examples

Scrivere un dataframe in un file di testo e leggerlo di nuovo.

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