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. Dekompresyon hatasında bir özel durum oluşturur.

Sözdizimi

from pyspark.sql import functions as dbf

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

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