texte (DataStreamReader)

Charge un flux de fichier texte et renvoie un DataFrame dont le schéma start par une colonne de chaîne de caractères nommée value, suivie de toutes les colonnes partitionnées. Les fichiers texte doivent être encodés en UTF-8. Chaque ligne du fichier texte est une nouvelle ligne dans le DataFrame résultant par default.

Syntaxe

text(path, **options)

parameter

parameter	Type	Description
path	str	Chemin pour la saisie de texte.

parameter	Type	Description
path	str	Chemin pour la saisie de texte.

Renvoie

DataFrame

Exemples

Charger un Stream depuis un fichier texte temporaire :

Python

import tempfile
import time
with tempfile.TemporaryDirectory(prefix="text") as d:
    spark.createDataFrame(
        [("hello",), ("this",)]).write.mode("overwrite").format("text").save(d)
    q = spark.readStream.text(d).writeStream.format("console").start()
    time.sleep(3)
    q.stop()