assert_true

Zwraca null wartość , jeśli kolumna wejściowa to true; zgłasza wyjątek z podanym komunikatem o błędzie w przeciwnym razie.

Składnia

from pyspark.sql import functions as sf

sf.assert_true(col, errMsg=None)

Parametry

Parameter	Typ	Description
col	pyspark.sql.Column lub str	Nazwa kolumny lub kolumna reprezentująca kolumnę wejściową do przetestowania.
errMsg	pyspark.sql.Column lub str, opcjonalnie	Literał lub kolumna ciągu języka Python zawierająca komunikat o błędzie.

Zwraca

pyspark.sql.Column: null jeśli kolumna wejściowa jest true w przeciwnym razie zgłasza błąd z określonym komunikatem.

Przykłady

Przykład 1. Potwierdzenie rzeczywistego warunku

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

Przykład 2. Potwierdzenie z komunikatem o błędzie kolumny

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

Przykład 3. Potwierdzenie z niestandardowym komunikatem o błędzie

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