raise_error

Создает исключение с предоставленным сообщением об ошибке.

Синтаксис

from pyspark.sql import functions as sf

sf.raise_error(errMsg)

Параметры

Параметр	Тип	Description
errMsg	pyspark.sql.Column или str	Строковый литерал Python или столбец, содержащий сообщение об ошибке.

Возвраты

pyspark.sql.Column: вызывает ошибку с указанным сообщением.

Примеры

Пример 1. Создание настраиваемого сообщения об ошибке

from pyspark.sql import functions as sf
spark.range(1).select(sf.raise_error("My error message")).show()

java.lang.RuntimeException: My error message