pyspark.sql.functions.
raise_error
(
errMsg
:
Union
[
pyspark.sql.column.Column
,
str
]
)
→ pyspark.sql.column.Column
[source]
¶
抛出一个带有提供的错误消息的异常。
在版本 3.1.0 中新增。
在版本 3.4.0 中更改: 支持 Spark 连接。
示例
>>> df = spark.range(1)
>>> df.select(raise_error("My error message")).show()
...
java.lang.RuntimeException: My error message
...