共用方式為


validate_utf8

若輸入值對應於有效的 UTF-8 字串,則回傳;否則會產生錯誤。

關於對應的 Databricks SQL 函式,請參見 validate_utf8 函數

語法

from pyspark.databricks.sql import functions as dbf

dbf.validate_utf8(str=<str>)

參數

參數 類型 Description
str pyspark.sql.Columnstr 一列字串,每個字串代表一個 UTF-8 位元組序列。

退貨

pyspark.sql.Column:輸入字串若是有效的 UTF-8 字串,否則錯誤。

範例

from pyspark.databricks.sql import functions as dbf
spark.range(1).select(dbf.validate_utf8(dbf.lit("SparkSQL"))).show()