zstd_decompress

Retourne la valeur décompressée d’expr à l’aide de Zstandard. Prend en charge les données compressées en mode passe unique et en mode streaming. En cas d’échec de la décompression, elle lève une exception.

Syntaxe

from pyspark.databricks.sql import functions as dbf

dbf.zstd_decompress(input=<input>)

Paramètres

Paramètre	Type	Descriptif
input	pyspark.sql.Column ou str	Valeur binaire à décompresser.

Retours

pyspark.sql.Column: nouvelle colonne qui contient une valeur non compressée.

Examples

from pyspark.databricks.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)

+----------------------------------------------------------------------------------------------------------------------------------+
|result                                                                                                                            |
+----------------------------------------------------------------------------------------------------------------------------------+
|Apache Spark Apache Spark Apache Spark Apache Spark Apache Spark Apache Spark Apache Spark Apache Spark Apache Spark Apache Spark |
+----------------------------------------------------------------------------------------------------------------------------------+