xml (DataStreamReader)

Memuat aliran file XML dan mengembalikan hasilnya sebagai DataFrame. Jika schema tidak ditentukan, skema input disimpulkan dari data.

Sintaksis

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

Parameter-parameternya

Parameter	Tipe	Deskripsi
path	str	Jalur untuk input XML.
schema	StructType atau str, opsional	Skema sebagai string berformat StructType atau DDL (misalnya, col0 INT, col1 DOUBLE).

Pengembalian Barang

DataFrame

Examples

Tulis DataFrame ke XML dan baca kembali sebagai aliran:

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