zstd_decompress

Retourneert de gedecomprimeerde waarde van expr met behulp van Zstandard. Ondersteunt gegevens die zijn gecomprimeerd in zowel de modus voor één wachtwoord als de streamingmodus. Bij decompressiefout wordt er een uitzondering gegenereerd.

Syntaxis

from pyspark.databricks.sql import functions as dbf

dbf.zstd_decompress(input=<input>)

Parameterwaarden

Kenmerk	Typologie	Description
input	pyspark.sql.Column of str	De binaire waarde die moet worden gedecomprimeren.

Retouren

pyspark.sql.Column: Een nieuwe kolom die een niet-gecomprimeerde waarde bevat.

Voorbeelden

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