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.Column или str	Столбец строк, каждый из которых представляет последовательность байтов 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()