Поделиться через


try_to_binary

Это специальная версия 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()