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, une exception est levée.
Syntaxe
Python
from pyspark.sql import functions as dbf
dbf.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
Python
from pyspark.sql import functions as dbf
df = spark.createDataFrame([("KLUv/SCCpQAAaEFwYWNoZSBTcGFyayABABLS+QU=",)], ["input"])
df.select(dbf.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 |
+----------------------------------------------------------------------------------------------------------------------------------+