raise_error

Gera uma exceção com a mensagem de erro fornecida.

Sintaxe

from pyspark.sql import functions as sf

sf.raise_error(errMsg)

Parâmetros

Parâmetro	Tipo	Description
errMsg	pyspark.sql.Column ou str	Uma coluna ou literal de cadeia de caracteres python que contém a mensagem de erro.

Devoluções

pyspark.sql.Column: lança um erro com a mensagem especificada.

Exemplos

Exemplo 1: Gerar uma mensagem de erro personalizada

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

java.lang.RuntimeException: My error message