エラーを発生させる

指定されたエラー メッセージとともに例外をスローします。

構文

Python

from pyspark.sql import functions as sf

sf.raise_error(errMsg)

パラメーター

パラメーター	Type	説明
errMsg	pyspark.sql.Column またはstr	エラー メッセージを含む Python 文字列リテラルまたは列。

戻り値

pyspark.sql.Column: 指定されたメッセージでエラーをスローします。

例

例1 : カスタムエラーメッセージを表示する

Python

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

Output

java.lang.RuntimeException: My error message