Bagikan melalui


to_xml

Mengonversi kolom yang berisi menjadi StructType string XML. Melempar pengecualian, dalam kasus jenis yang tidak didukung.

Syntax

from pyspark.sql import functions as sf

sf.to_xml(col, options=None)

Parameter-parameternya

Pengaturan Tipe Description
col pyspark.sql.Column atau str Nama kolom yang berisi struct.
options dict, opsional Opsi untuk mengontrol konversi. Menerima opsi yang sama dengan sumber data XML.

Pengembalian Barang

pyspark.sql.Column: string XML yang dikonversi dari yang diberikan StructType.

Examples

from pyspark.sql import Row, functions as sf
data = [(1, Row(age=2, name='Alice'))]
df = spark.createDataFrame(data, ("key", "value"))
df.select(sf.to_xml(df.value, {'rowTag':'person'}).alias("xml")).collect()
[Row(xml='<person>\n    <age>2</age>\n    <name>Alice</name>\n</person>')]