try_to_binary

Jest to specjalna wersja to_binary , która wykonuje tę samą operację, ale zwraca wartość NULL zamiast zgłaszać błąd, jeśli nie można wykonać konwersji.

Aby uzyskać odpowiednią funkcję SQL usługi Databricks, zobacz try_to_binary funkcja.

Składnia

from pyspark.databricks.sql import functions as dbf

dbf.try_to_binary(col=<col>, format=<format>)

Parametry

Parameter	Typ	Description
col	pyspark.sql.Column lub str	Dane wejściowe kolumny lub ciągi.
format	pyspark.sql.Column lub str, optional	format używany do konwertowania wartości binarnych.

Przykłady

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()