會拋出一個包含錯誤訊息的例外。
語法
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