texte (DataFrameWriter)

Enregistre le contenu du DataFrame fichier texte dans le chemin d’accès spécifié. Les fichiers texte sont encodés en UTF-8.

Syntaxe

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

Paramètres

Paramètre Type Description
path str Chemin d’accès dans n’importe quel système de fichiers pris en charge par Hadoop.
compression str, facultatif Codec de compression à utiliser.
lineSep str, facultatif Séparateur de ligne à utiliser.

Retours

Aucun

Remarques

Il DataFrame ne doit avoir qu’une seule colonne de type chaîne. Chaque ligne devient une nouvelle ligne dans le fichier de sortie.

Exemples

Écrivez un DataFrame dans un fichier texte et lisez-le.

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