raise_error

Zgłasza wyjątek z podanym komunikatem o błędzie.

Składnia

from pyspark.sql import functions as sf

sf.raise_error(errMsg)

Parametry

Parameter	Typ	Description
errMsg	pyspark.sql.Column lub str	Literał lub kolumna ciągu języka Python zawierająca komunikat o błędzie.

Zwraca

pyspark.sql.Column: zgłasza błąd z określonym komunikatem.

Przykłady

Przykład 1. Zgłaszanie niestandardowego komunikatu o błędzie

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

java.lang.RuntimeException: My error message