Condividi tramite


raise_error

Genera un'eccezione con il messaggio di errore specificato.

Sintassi

from pyspark.sql import functions as sf

sf.raise_error(errMsg)

Parametri

Parametro TIPO Description
errMsg pyspark.sql.Column o str Valore letterale o colonna stringa Python contenente il messaggio di errore.

Restituzioni

pyspark.sql.Column: genera un errore con il messaggio specificato.

Esempi

Esempio 1: Generare un messaggio di errore personalizzato

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