raise_error

Sağlanan hata iletisiyle bir özel durum oluşturur.

Sözdizimi

from pyspark.sql import functions as sf

sf.raise_error(errMsg)

Parametreler

Parametre	Türü	Description
errMsg	pyspark.sql.Column veya str	Hata iletisini içeren python dizesi değişmez değeri veya sütunu.

İade

pyspark.sql.Column: belirtilen iletiyle bir hata oluşturur.

Örnekler

Örnek 1: Özel hata iletisi oluşturma

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

java.lang.RuntimeException: My error message