raise_error

Melempar pengecualian dengan pesan kesalahan yang telah disediakan.

Syntax

from pyspark.sql import functions as sf

sf.raise_error(errMsg)

Parameter-parameternya

Pengaturan	Tipe	Description
errMsg	pyspark.sql.Column atau str	String Python literal atau kolom yang berisi pesan kesalahan.

Pengembalian Barang

pyspark.sql.Column: melemparkan kesalahan dengan pesan tertentu.

Examples

Contoh 1: Memunculkan pesan kesalahan kustom

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

java.lang.RuntimeException: My error message