Zstandard를 사용하여 expr의 압축 해제된 값을 반환합니다. 단일 패스 모드와 스트리밍 모드 모두에서 압축된 데이터를 지원합니다. 압축 해제 실패시 예외가 throw됩니다.
문법
from pyspark.databricks.sql import functions as dbf
dbf.zstd_decompress(input=<input>)
매개 변수
| 매개 변수 | 유형 | Description |
|---|---|---|
input |
pyspark.sql.Column 또는 str |
압축을 해제할 이진 값입니다. |
Returns
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 |
+----------------------------------------------------------------------------------------------------------------------------------+