try_zstd_decompress
Renvoie la valeur décompressée de l'expression en utilisant Zstandard. Prend en charge les données compressées à la fois en mode passe unique et en mode streaming. En cas d'échec de la décompression, elle renvoie NULL.
Syntaxe
Python
from pyspark.sql import functions as dbf
dbf.try_zstd_decompress(input=<input>)
parameter
parameter | Type | Description |
|---|---|---|
|
| La valeur binaire à décompresser. |
Renvoie
pyspark.sql.Column: une nouvelle colonne qui contient une valeur non compressée.
Exemples
Exemple 1 : Décompresser les données à l'aide de Zstandard
Python
from pyspark.sql import functions as dbf
df = spark.createDataFrame([("KLUv/SCCpQAAaEFwYWNoZSBTcGFyayABABLS+QU=",)], ["input"])
df.select(dbf.try_zstd_decompress(dbf.unbase64(df.input)).cast("string").alias("result")).show(truncate=False)
Output
+----------------------------------------------------------------------------------------------------------------------------------+
|result |
+----------------------------------------------------------------------------------------------------------------------------------+
|Apache Spark Apache Spark Apache Spark Apache Spark Apache Spark Apache Spark Apache Spark Apache Spark Apache Spark Apache Spark |
+----------------------------------------------------------------------------------------------------------------------------------+
Exemple 2 : Décompresser l'entrée non valide
Python
from pyspark.sql import functions as dbf
df = spark.createDataFrame([("invalid input",)], ["input"])
df.select(dbf.try_zstd_decompress(dbf.unbase64(df.input)).cast("string").alias("result")).show(truncate=False)
Output
+------+
|result|
+------+
|NULL |
+------+