指定したformatに基づいて、入力colをバイナリ値に変換します。
formatには、"hex"、"utf-8"、"utf8"、または "base64" の大文字と小文字を区別しない文字列リテラルを指定できます。 既定では、 format を省略した場合、変換のバイナリ形式は "hex" になります。 入力パラメーターの少なくとも 1 つが NULL の場合、この関数は NULL を返します。
対応する Databricks SQL 関数については、 to_binary 関数を参照してください。
構文
from pyspark.databricks.sql import functions as dbf
dbf.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()