raise_error

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

Sintaxe

Python

from pyspark.sql import functions as sf

sf.raise_error(errMsg)

Parâmetros

Parâmetro	Tipo	Descrição
errMsg	pyspark.sql.Column ou str	Uma string literal Python ou uma coluna contendo a mensagem de erro.

Devoluções

pyspark.sql.Column: gera um erro com a mensagem especificada.

Exemplos

Exemplo 1 : Exibir uma mensagem de erro personalizada

Python

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

Output

java.lang.RuntimeException: My error message