XPath

Devolve um array de cadeias de valores dentro dos nós do xml que correspondem à expressão XPath.

Sintaxe

from pyspark.sql import functions as sf

sf.xpath(xml, path)

Parâmetros

Parâmetro	Tipo	Description
xml	pyspark.sql.Column ou str	Nome da coluna ou coluna XML.
path	pyspark.sql.Column ou str	Expressão de XPath.

Examples

from pyspark.sql import functions as sf
df = spark.createDataFrame(
    [('<a><b>b1</b><b>b2</b><b>b3</b><c>c1</c><c>c2</c></a>',)], ['x'])
df.select(sf.xpath(df.x, sf.lit('a/b/text()'))).show()

+--------------------+
|xpath(x, a/b/text())|
+--------------------+
|        [b1, b2, b3]|
+--------------------+