to_xml

Convertit une colonne contenant un(e) StructType en une chaîne XML. Lève une exception, dans le cas d'un type non pris en charge.

Syntaxe

Python

from pyspark.sql import functions as sf

sf.to_xml(col, options=None)

parameter

parameter	Type	Description
col	pyspark.sql.Column ou str	Nom de la colonne contenant une structure.
options	dictionnaire, facultatif	Options pour contrôler la conversion. Accepte les mêmes options que la source de données XML.

parameter	Type	Description
col	pyspark.sql.Column ou str	Nom de la colonne contenant une structure.
options	dictionnaire, facultatif	Options pour contrôler la conversion. Accepte les mêmes options que la source de données XML.

Renvoie

pyspark.sql.Column: une chaîne XML convertie à partir de StructType.

Exemples

Python

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

Output

[Row(xml='<person>\n    <age>2</age>\n    <name>Alice</name>\n</person>')]