try_url_decode

Это специальная версия url_decode , которая выполняет ту же операцию, но возвращает значение NULL вместо того, чтобы вызывать ошибку, если декодирование не может быть выполнено.

Синтаксис

from pyspark.sql import functions as sf

sf.try_url_decode(str)

Параметры

Параметр	Тип	Description
str	pyspark.sql.Column или str	Столбец строк, каждый из которых представляет строку, закодированную URL-адресом.

Возвраты

pyspark.sql.Column: новый столбец строк, каждый из которых представляет декодированную строку.

Примеры

Пример 1. Декодирование строки в кодировке URL-адреса

from pyspark.sql import functions as sf
df = spark.createDataFrame([("https%3A%2F%2Fspark.apache.org",)], ["url"])
df.select(sf.try_url_decode(df.url)).show(truncate=False)

+------------------------+
|try_url_decode(url)     |
+------------------------+
|https://spark.apache.org|
+------------------------+

Пример 2. Возвращает значение NULL, если декодирование невозможно выполнить

from pyspark.sql import functions as sf
df = spark.createDataFrame([("https%3A%2F%2spark.apache.org",)], ["url"])
df.select(sf.try_url_decode(df.url)).show()

+-------------------+
|try_url_decode(url)|
+-------------------+
|               NULL|
+-------------------+