Nota
L'accesso a questa pagina richiede l'autorizzazione. È possibile provare ad accedere o modificare le directory.
L'accesso a questa pagina richiede l'autorizzazione. È possibile provare a modificare le directory.
Restituisce null se la colonna di input è true; genera un'eccezione con il messaggio di errore specificato in caso contrario.
Sintassi
from pyspark.sql import functions as sf
sf.assert_true(col, errMsg=None)
Parametri
| Parametro | TIPO | Description |
|---|---|---|
col |
pyspark.sql.Column o str |
Nome o colonna di colonna che rappresenta la colonna di input da testare. |
errMsg |
pyspark.sql.Column o str, facoltativo |
Valore letterale o colonna stringa Python contenente il messaggio di errore. |
Restituzioni
pyspark.sql.Column: null se la colonna di input in true caso contrario genera un errore con il messaggio specificato.
Esempi
Esempio 1: Asserzione di una condizione vera
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|
+---+---+--------------------------------------------+
Esempio 2: Assert con messaggio di errore della colonna
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|
+---+---+-----------------------+
Esempio 3: Assert con messaggio di errore personalizzato
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|
+---+---+---------------------------+