抛出包含提供的错误消息的异常。
Syntax
from pyspark.sql import functions as sf
sf.raise_error(errMsg)
参数
| 参数 | 类型 | Description |
|---|---|---|
errMsg |
pyspark.sql.Column 或 str |
包含错误消息的 Python 字符串文本或列。 |
退货
pyspark.sql.Column：引发具有指定消息的错误。
例子
示例 1：引发自定义错误消息
from pyspark.sql import functions as sf
spark.range(1).select(sf.raise_error("My error message")).show()
java.lang.RuntimeException: My error message