제공된 오류 메시지와 함께 예외를 발생시킵니다.
문법
from pyspark.sql import functions as sf
sf.raise_error(errMsg)
매개 변수
| 매개 변수 | 유형 | Description |
|---|---|---|
errMsg |
pyspark.sql.Column 또는 str |
오류 메시지가 포함된 Python 문자열 리터럴 또는 열입니다. |
Returns
pyspark.sql.Column: 지정된 메시지와 함께 오류를 throw합니다.
예시
예제 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