raise_error

Kivételt jelez a megadott hibaüzenettel.

Szemantika

from pyspark.sql import functions as sf

sf.raise_error(errMsg)

Paraméterek

Paraméter	Típus	Description
errMsg	pyspark.sql.Column vagy str	A hibaüzenetet tartalmazó Python-sztringkonstans vagy -oszlop.

Visszatérítések

pyspark.sql.Column: hibát jelez a megadott üzenettel.

Példák

1. példa: Egyéni hibaüzenet létrehozása

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

java.lang.RuntimeException: My error message