texte (DataStreamReader)

Charge un flux de fichiers texte et retourne un DataFrame dont le schéma commence par une colonne de chaîne nommée value, suivie de toutes les colonnes partitionnée. 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 défaut.

Syntaxe

text(path, **options)

Paramètres

Retours

DataFrame

Exemples

Chargez un flux à partir d’un fichier texte temporaire :

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()