xpath

Zwraca tablicę ciągów wartości w węzłach xml, które są zgodne z wyrażeniem XPath.

Składnia

from pyspark.sql import functions as sf

sf.xpath(xml, path)

Parametry

Parameter	Typ	Description
xml	pyspark.sql.Column lub str	Nazwa kolumny LUB kolumny XML.
path	pyspark.sql.Column lub str	Wyrażenie XPath.

Przykłady

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]|
+--------------------+