pyspark.sql.functions.try_to_binary ¶

pyspark.sql.functions. try_to_binary ( col : ColumnOrName , format : Optional [ ColumnOrName ] = None ) → pyspark.sql.column.Column [source] ¶

这是 to_binary 的一个特殊版本，执行相同的操作，但如果转换无法执行，则返回NULL值而不是引发错误。

新增于版本 3.5.0。

Parameters

col Column or str: 输入列或字符串。
format Column or str, optional: 用于转换二进制值的格式。

示例

           >>> df = spark.createDataFrame([("abc",)], ["e"])
>>> df.select(try_to_binary(df.e, lit("utf-8")).alias('r')).collect()
[Row(r=bytearray(b'abc'))]

          

           >>> df = spark.createDataFrame([("414243",)], ["e"])
>>> df.select(try_to_binary(df.e).alias('r')).collect()
[Row(r=bytearray(b'ABC'))]

          

pyspark.sql.functions.try_sum

pyspark.sql.functions.try_to_number