Compartir vía


to_xml

Convierte una columna que contiene una StructType en una cadena XML. Produce una excepción, en el caso de un tipo no admitido.

Syntax

from pyspark.sql import functions as sf

sf.to_xml(col, options=None)

Parámetros

Parámetro Tipo Description
col pyspark.sql.Column o str Nombre de la columna que contiene una estructura.
options dict, opcional Opciones para controlar la conversión. Acepta las mismas opciones que el origen de datos XML.

Devoluciones

pyspark.sql.Column: una cadena XML convertida de dado 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>')]