zstd_decompress

Devuelve el valor descomprimido de expr mediante Zstandard. Admite datos comprimidos tanto en modo de paso único como en modo de streaming. En caso de error de descompresión, produce una excepción.

Syntax

from pyspark.sql import functions as dbf

dbf.zstd_decompress(input=<input>)

Parámetros

Parámetro	Tipo	Description
input	pyspark.sql.Column o str	Valor binario que se va a descomprimir.

Devoluciones

pyspark.sql.Column: una nueva columna que contiene un valor sin comprimir.

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