raise_error

Löst eine Ausnahme mit der bereitgestellten Fehlermeldung aus.

Syntax

from pyspark.sql import functions as sf

sf.raise_error(errMsg)

Die Parameter

Parameter	Typ	Description
errMsg	pyspark.sql.Column oder str	Ein Python-Zeichenfolgenliteral oder eine Spalte, die die Fehlermeldung enthält.

Rückkehr

pyspark.sql.Column: löst einen Fehler mit der angegebenen Nachricht aus.

Examples

Beispiel 1: Auslösen einer benutzerdefinierten Fehlermeldung

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

java.lang.RuntimeException: My error message