try_zstd_decompress

Zstandard を使用して expr の解凍された値を返します。シングルパス モードとストリーミング モードの両方で圧縮されたデータをサポートします。解凍に失敗した場合は NULL を返します。

構文

Python

from pyspark.databricks.sql import functions as dbf

dbf.try_zstd_decompress(input=<input>)

パラメーター

パラメーター	Type	説明
input	pyspark.sql.Column または str	解凍するバイナリ値。

戻り値

pyspark.sql.Column: 圧縮されていない値を含む新しい列。

例

例1 : Zstandardを使用してデータを解凍する

Python

from pyspark.databricks.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)

Output

+----------------------------------------------------------------------------------------------------------------------------------+
|result                                                                                                                            |
+----------------------------------------------------------------------------------------------------------------------------------+
|Apache Spark Apache Spark Apache Spark Apache Spark Apache Spark Apache Spark Apache Spark Apache Spark Apache Spark Apache Spark |
+----------------------------------------------------------------------------------------------------------------------------------+

例2 : 無効な入力を解凍する

Python

from pyspark.databricks.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)

Output

+------+
|result|
+------+
|NULL  |
+------+