xpath_int(xml, path)
Описание
Функция xpath_int()
извлекает целочисленное значение из XML-документа по указанному XPath-выражению.
Параметры
xml
: Column - столбец с XML-строкамиpath
: String - XPath-выражение для извлечения целочисленного значения
Возвращаемое значение
Integer - извлеченное целочисленное значение
Пример использования
from pyspark.sql.functions import xpath_int
from pyspark.sql import SparkSession
# Создаем SparkSession
spark = SparkSession.builder.appName("xpath_int_example").getOrCreate()
# Создаем DataFrame с XML-строками
data = [
("<product><name>Laptop</name><stock>10</stock></product>"),
("<product><name>Phone</name><stock>5</stock></product>")
]
df = spark.createDataFrame(data, ["xml"])
# Извлекаем количество на складе
result = df.select(
"xml",
xpath_int("xml", "product/stock").alias("stock")
).show(truncate=False)
# Результат:
# +----------------------------------------------+-----+
# |xml |stock|
# +----------------------------------------------+-----+
# |<product><name>Laptop</name><stock>10</stock></product>|10 |
# |<product><name>Phone</name><stock>5</stock></product>|5 |
# +----------------------------------------------+-----+
Примечания
- XPath-выражение должно быть корректным
- Если элемент не найден или не может быть преобразован в целое число, возвращается NULL
- NULL значения в XML возвращают NULL
- Для работы с XML также используйте:
xpath()
для извлечения значенийxpath_boolean()
для проверки условийxpath_double()
для извлечения чиселxpath_long()
для извлечения длинных целых чиселxpath_short()
для извлечения коротких целых чиселxpath_string()
для извлечения строкxml_tuple()
для извлечения нескольких значений