raise_error

Lanza una excepción con el mensaje de error proporcionado.

Syntax

from pyspark.sql import functions as sf

sf.raise_error(errMsg)

Parámetros

Parámetro	Tipo	Description
errMsg	pyspark.sql.Column o str	Literal o columna de cadena de Python que contiene el mensaje de error.

Devoluciones

pyspark.sql.Column: produce un error con el mensaje especificado.

Examples

Ejemplo 1: Generar un mensaje de error personalizado

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

java.lang.RuntimeException: My error message