xml (DataStreamReader)

XML dosya akışını yükler ve sonucu DataFrame olarak döndürür. Belirtilmezse schema , giriş şeması verilerden çıkarılır.

Sözdizimi

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

Parametreler

Parametre Türü Açıklama
path str XML girişinin yolu.
schema StructType veya str, isteğe bağlı StructType veya DDL biçimli dize olarak şema (örneğin, col0 INT, col1 DOUBLE).

İadeler

DataFrame

Örnekler

XML'ye bir DataFrame yazın ve akış olarak geri okuyun:

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()
  • Last updated on