Delen via


raise_error

Genereert een uitzondering met het opgegeven foutbericht.

Syntaxis

from pyspark.sql import functions as sf

sf.raise_error(errMsg)

Parameterwaarden

Kenmerk Typologie Description
errMsg pyspark.sql.Column of str Een letterlijke python-tekenreeks of -kolom met het foutbericht.

Retouren

pyspark.sql.Column: genereert een fout met het opgegeven bericht.

Voorbeelden

Voorbeeld 1: Een aangepast foutbericht genereren

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