zstd_decompress

Vrátí dekomprimovanou hodnotu výrazu pomocí Zstandard. Podporuje data komprimovaná v režimu s jedním průchodem i v režimu streamování. Při selhání dekomprese vyvolá výjimku.

Syntaxe

from pyspark.sql import functions as dbf

dbf.zstd_decompress(input=<input>)

Parametry

Parameter	Typ	Description
input	pyspark.sql.Column nebo str	Binární hodnota pro dekompresi.

Návraty

pyspark.sql.Column: Nový sloupec, který obsahuje nekomprimovanou hodnotu.

Examples

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)

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