assert_true

Devuelve null si la columna de entrada es true; produce una excepción con el mensaje de error proporcionado de lo contrario.

Syntax

from pyspark.sql import functions as sf

sf.assert_true(col, errMsg=None)

Parámetros

Parámetro	Tipo	Description
col	pyspark.sql.Column o str	Nombre de columna o columna que representa la columna de entrada que se va a probar.
errMsg	pyspark.sql.Column o str, opcional	Literal o columna de cadena de Python que contiene el mensaje de error.

Devoluciones

pyspark.sql.Column: null si la columna de entrada produce true un error con el mensaje especificado.

Examples

Ejemplo 1: Aserción de una condición verdadera

from pyspark.sql import functions as sf
df = spark.createDataFrame([(0, 1)], ['a', 'b'])
df.select('*', sf.assert_true(df.a < df.b)).show()

+---+---+--------------------------------------------+
|  a|  b|assert_true((a < b), '(a < b)' is not true!)|
+---+---+--------------------------------------------+
|  0|  1|                                        NULL|
+---+---+--------------------------------------------+

Ejemplo 2: Aserción con mensaje de error de columna

from pyspark.sql import functions as sf
df = spark.createDataFrame([(0, 1)], ['a', 'b'])
df.select('*', sf.assert_true(df.a < df.b, df.a)).show()

+---+---+-----------------------+
|  a|  b|assert_true((a < b), a)|
+---+---+-----------------------+
|  0|  1|                   NULL|
+---+---+-----------------------+

Ejemplo 3: Aserción con mensaje de error personalizado

from pyspark.sql import functions as sf
df = spark.createDataFrame([(0, 1)], ['a', 'b'])
df.select('*', sf.assert_true(df.a < df.b, 'error')).show()

+---+---+---------------------------+
|  a|  b|assert_true((a < b), error)|
+---+---+---------------------------+
|  0|  1|                       NULL|
+---+---+---------------------------+