try_zstd_decompress

Zstandard kullanarak ifadenin sıkıştırılmış değerini döndürür. Hem tek geçiş modunda hem de akış modunda sıkıştırılmış verileri destekler. Sıkıştırmayı açma hatasında NULL döndürür.

Sözdizimi

from pyspark.sql import functions as dbf

dbf.try_zstd_decompress(input=<input>)

Parametreler

Parametre	Türü	Description
input	pyspark.sql.Column veya str	Sıkıştırmayı açmak için ikili değer.

İade

pyspark.sql.Column: Sıkıştırılmamış değer içeren yeni bir sütun.

Örnekler

Örnek 1: Zstandard kullanarak verileri açma

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

Örnek 2: Geçersiz girişin sıkıştırması kaldır

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