これは、同じ操作を実行する特殊なバージョンの to_binary ですが、変換を実行できない場合はエラーを発生させる代わりに NULL 値を返します。
対応する Databricks SQL 関数については、 try_to_binary 関数を参照してください。
構文
from pyspark.databricks.sql import functions as dbf
dbf.try_to_binary(col=<col>, format=<format>)
パラメーター
| パラメーター | タイプ | Description |
|---|---|---|
col |
pyspark.sql.Column または str |
入力列または文字列。 |
format |
pyspark.sql.Column または str, optional |
バイナリ値の変換に使用する形式。 |
例示
from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame([("abc",)], ["e"])
df.select(dbf.try_to_binary(df.e, dbf.lit("utf-8")).alias('r')).collect()
from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame([("414243",)], ["e"])
df.select(dbf.try_to_binary(df.e).alias('r')).collect()