raise_error

Vyvolá výjimku se zadanou chybovou zprávou.

Syntaxe

from pyspark.sql import functions as sf

sf.raise_error(errMsg)

Parametry

Parameter	Typ	Description
errMsg	pyspark.sql.Column nebo str	Řetězcový literál pythonu nebo sloupec obsahující chybovou zprávu.

Návraty

pyspark.sql.Column: vyvolá chybu se zadanou zprávou.

Examples

Příklad 1: Vyvolání vlastní chybové zprávy

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

java.lang.RuntimeException: My error message