try_url_decode

Jedná se o speciální verzi url_decode , která provádí stejnou operaci, ale vrátí hodnotu NULL místo vyvolání chyby, pokud dekódování nelze provést.

Syntaxe

from pyspark.sql import functions as sf

sf.try_url_decode(str)

Parametry

Parameter Typ Description
str pyspark.sql.Column nebo str Sloupec řetězců, z nichž každý představuje řetězec kódovaný adresou URL.

Návraty

pyspark.sql.Column: Nový sloupec řetězců, z nichž každý představuje dekódovaný řetězec.

Examples

Příklad 1: Dekódování řetězce kódovaného adresou 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|
+------------------------+

Příklad 2: Vrátí hodnotu NULL, pokud dekódování nelze provést.

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