to_xml

StructTypeを含む列を XML 文字列に変換します。サポートされていない型の場合は例外をスローします。

構文

Python

from pyspark.sql import functions as sf

sf.to_xml(col, options=None)

パラメーター

パラメーター	Type	説明
col	pyspark.sql.Column または文字列	構造体を含む列の名前。
options	辞書（オプション）	変換を制御するためのオプション。XML データ ソースと同じオプションを受け入れます。

戻り値

pyspark.sql.Column: 指定されたStructTypeから変換された XML 文字列。

例

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