xml (DataStreamReader)

Načte datový proud souboru XML a vrátí výsledek jako datový rámec. Pokud schema není zadáno, vstupní schéma je odvozeno z dat.

Syntaxe

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

Parametry

Parameter	Typ	Description
path	str	Cesta pro vstup XML
schema	StructType nebo str, volitelné	Schéma jako řetězec ve formátu StructType nebo DDL (například col0 INT, col1 DOUBLE).

Návraty

DataFrame

Příklady

Zapište datový rámec do XML a přečtěte si ho zpět jako datový proud:

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