to_xml

Převede sloupec obsahující StructType řetězec XML. Vyvolá výjimku v případě nepodporovaného typu.

Syntaxe

from pyspark.sql import functions as sf

sf.to_xml(col, options=None)

Parametry

Parameter Typ Description
col pyspark.sql.Column nebo str Název sloupce obsahujícího strukturu
options diktování, volitelné Možnosti pro řízení převodu Přijímá stejné možnosti jako zdroj dat XML.

Návraty

pyspark.sql.Column: řetězec XML převedený z daného 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>')]