xml (DataStreamReader)

Charge un stream de fichiers XML et renvoie le résultat sous forme de DataFrame. Si schema n'est pas spécifié, le schéma d'entrée est déduit des données.

Syntaxe

xml(path, schema=None, **options)

parameter

parameter	Type	Description
path	str	Chemin d'accès de l'entrée XML.
schema	StructType ou str, facultatif.	Schéma en tant que StructType ou chaîne formatée DDL (par exemple, col0 INT, col1 DOUBLE).

parameter	Type	Description
path	str	Chemin d'accès de l'entrée XML.
schema	StructType ou str, facultatif.	Schéma en tant que StructType ou chaîne formatée DDL (par exemple, col0 INT, col1 DOUBLE).

Renvoie

DataFrame

Exemples

Écrire un DataFrame en XML et le relire en tant que Stream :

Python

import tempfile
import time
with tempfile.TemporaryDirectory(prefix="xml") as d:
    spark.createDataFrame(
        [{"age": 100, "name": "Hyukjin Kwon"}]
    ).write.mode("overwrite").option("rowTag", "person").xml(d)
    q = spark.readStream.schema(
        "age INT, name STRING"
    ).xml(d, rowTag="person").writeStream.format("console").start()
    time.sleep(3)
    q.stop()