try_zstd_decompress

Devolve o valor descomprimido de expr usando Zstandard. Suporta dados comprimidos tanto em modo single-pass como em modo streaming. Em caso de falha de descompressão, devolve NULL.

Sintaxe

from pyspark.databricks.sql import functions as dbf

dbf.try_zstd_decompress(input=<input>)

Parâmetros

Parâmetro	Tipo	Description
input	pyspark.sql.Column ou str	O valor binário para descomprimir.

Devoluções

pyspark.sql.Column: Uma nova coluna que contém um valor não comprimido.

Examples

Exemplo 1: Descomprimir dados usando 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 |
+----------------------------------------------------------------------------------------------------------------------------------+

Exemplo 2: Descomprimir entrada inválida

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