try_zstd_decompress

Mengembalikan nilai expr yang didekompresi menggunakan Zstandard. Mendukung data yang dikompresi dalam mode akses menyeluruh dan mode streaming. Pada kegagalan dekompresi, ia mengembalikan NULL.

Syntax

from pyspark.sql import functions as dbf

dbf.try_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

Contoh 1: Mendekompresi data menggunakan Zstandard

from pyspark.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 |
+----------------------------------------------------------------------------------------------------------------------------------+

Contoh 2: Mendekompresi input yang tidak valid

from pyspark.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  |
+------+