Partager via


raise_error

Lève une exception avec le message d’erreur fourni.

Syntaxe

from pyspark.sql import functions as sf

sf.raise_error(errMsg)

Paramètres

Paramètre Type Descriptif
errMsg pyspark.sql.Column ou str Littéral ou colonne de chaîne Python contenant le message d’erreur.

Retours

pyspark.sql.Column: lève une erreur avec le message spécifié.

Examples

Exemple 1 : Déclencher un message d’erreur personnalisé

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