try_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 fout bij decompressie retourneert deze NULL.

Syntaxis

from pyspark.databricks.sql import functions as dbf

dbf.try_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

Voorbeeld 1: Gegevens decomprimeren met behulp van Zstandard

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

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

Voorbeeld 2: ongeldige invoer decomprimeren

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

+------+
|result|
+------+
|NULL  |
+------+