这是执行相同作的特殊版本 url_decode ,但如果无法执行解码,则返回 NULL 值,而不是引发错误。
Syntax
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|
+-------------------+