assert_true

Vrátí null , pokud je truevstupní sloupec ; vyvolá výjimku se zadanou chybovou zprávou jinak.

Syntaxe

from pyspark.sql import functions as sf

sf.assert_true(col, errMsg=None)

Parametry

Parameter	Typ	Description
col	pyspark.sql.Column nebo str	Název sloupce nebo sloupec, který představuje vstupní sloupec, který se má testovat.
errMsg	pyspark.sql.Column nebo str, volitelné	Řetězcový literál pythonu nebo sloupec obsahující chybovou zprávu.

Návraty

pyspark.sql.Column: null Pokud je true vstupní sloupec jinak vyvolá chybu se zadanou zprávou.

Examples

Příklad 1: Assert a true condition

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

Příklad 2: Assert s chybovou zprávou sloupce

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

Příklad 3: Assert s vlastní chybovou zprávou

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