lever_erreur

Lance une exception avec le message d'erreur fourni.

Syntaxe

Python

from pyspark.sql import functions as sf

sf.raise_error(errMsg)

parameter

parameter	Type	Description
errMsg	pyspark.sql.Column ou str	Un littéral de chaîne Python ou une colonne contenant le message d'erreur.

parameter	Type	Description
errMsg	pyspark.sql.Column ou str	Un littéral de chaîne Python ou une colonne contenant le message d'erreur.

Renvoie

pyspark.sql.Column: génère une erreur avec le message spécifié.

Exemples

Exemple 1 : Afficher un message d'erreur personnalisé

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