Kommentar
Åtkomst till den här sidan kräver auktorisering. Du kan prova att logga in eller ändra kataloger.
Åtkomst till den här sidan kräver auktorisering. Du kan prova att ändra kataloger.
Returnerar null om indatakolumnen är true; utlöser ett undantag med det angivna felmeddelandet annars.
Syntax
from pyspark.sql import functions as sf
sf.assert_true(col, errMsg=None)
Parameterar
| Parameter | Typ | Description |
|---|---|---|
col |
pyspark.sql.Column eller str |
Kolumnnamn eller kolumn som representerar den indatakolumn som ska testas. |
errMsg |
pyspark.sql.Column eller str, valfritt |
En Python-strängliteral eller kolumn som innehåller felmeddelandet. |
Retur
pyspark.sql.Column: null om indatakolumnen true annars utlöser ett fel med angivet meddelande.
Examples
Exempel 1: Bekräfta ett sant villkor
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|
+---+---+--------------------------------------------+
Exempel 2: Bekräfta med kolumnfelmeddelande
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|
+---+---+-----------------------+
Exempel 3: Bekräfta med anpassat felmeddelande
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|
+---+---+---------------------------+