Compartir a través de


xpath

Devuelve una matriz de cadenas de valores dentro de los nodos de xml que coinciden con la expresión XPath.

Syntax

from pyspark.sql import functions as sf

sf.xpath(xml, path)

Parámetros

Parámetro Tipo Description
xml pyspark.sql.Column o str Nombre de columna o columna XML.
path pyspark.sql.Column o str Expresión 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]|
+--------------------+