zstd_decompress

Mengembalikan nilai expr yang didekompresi menggunakan Zstandard. Mendukung data yang dikompresi dalam mode akses menyeluruh dan mode streaming. Pada kegagalan dekompresi, itu melemparkan pengecualian.

Syntax

from pyspark.sql import functions as dbf

dbf.zstd_decompress(input=<input>)

Parameter-parameternya

Pengaturan	Tipe	Description
input	pyspark.sql.Column atau str	Nilai biner untuk didekompresi.

Pengembalian Barang

pyspark.sql.Column: Kolom baru yang berisi nilai yang tidak dikompresi.

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