para_xml

Converte uma coluna contendo StructType em uma string XML. Lança uma exceção no caso de um tipo não suportado.

Sintaxe

Python

from pyspark.sql import functions as sf

sf.to_xml(col, options=None)

Parâmetros

Parâmetro	Tipo	Descrição
col	pyspark.sql.Column ou str	Nome da coluna que contém uma estrutura.
options	dicionário, opcional	Opções para controlar a conversão. Aceita as mesmas opções que a fonte de dados XML.

Devoluções

pyspark.sql.Column: uma string XML convertida a partir de StructType fornecido.

Exemplos

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>')]