assert_true

Retourneert null als de invoerkolom is true; genereert anders een uitzondering met het opgegeven foutbericht.

Syntaxis

from pyspark.sql import functions as sf

sf.assert_true(col, errMsg=None)

Parameterwaarden

Kenmerk	Typologie	Description
col	pyspark.sql.Column of str	Kolomnaam of kolom die de invoerkolom vertegenwoordigt die moet worden getest.
errMsg	pyspark.sql.Column of str, optioneel	Een letterlijke python-tekenreeks of -kolom met het foutbericht.

Retouren

pyspark.sql.Column: null als de invoerkolom true anders een fout met het opgegeven bericht genereert.

Voorbeelden

Voorbeeld 1: Een werkelijke voorwaarde bevestigen

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|
+---+---+--------------------------------------------+

Voorbeeld 2: Assert met kolomfoutbericht

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|
+---+---+-----------------------+

Voorbeeld 3: Assert met aangepast foutbericht

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|
+---+---+---------------------------+