使用 Zstandard 返回 expr 的解压缩值。 支持在单传递模式和流式处理模式下压缩的数据。 解压缩失败时，它会引发异常。
Syntax
from pyspark.databricks.sql import functions as dbf
dbf.zstd_decompress(input=<input>)
参数
| 参数 | 类型 | Description |
|---|---|---|
input |
pyspark.sql.Column 或 str |
要解压缩的二进制值。 |
退货
pyspark.sql.Column：包含未压缩值的新列。
例子
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 |
+----------------------------------------------------------------------------------------------------------------------------------+