Anmerkung
Der Zugriff auf diese Seite erfordert eine Genehmigung. Du kannst versuchen, dich anzumelden oder die Verzeichnisse zu wechseln.
Der Zugriff auf diese Seite erfordert eine Genehmigung. Du kannst versuchen , die Verzeichnisse zu wechseln.
Gibt zurück null , wenn die Eingabespalte lautet true; löst eine Ausnahme mit der bereitgestellten Fehlermeldung andernfalls aus.
Syntax
from pyspark.sql import functions as sf
sf.assert_true(col, errMsg=None)
Die Parameter
| Parameter | Typ | Description |
|---|---|---|
col |
pyspark.sql.Column oder str |
Spaltenname oder -spalte, die die zu testde Eingabespalte darstellt. |
errMsg |
pyspark.sql.Column oder str, optional |
Ein Python-Zeichenfolgenliteral oder eine Spalte, die die Fehlermeldung enthält. |
Rückkehr
pyspark.sql.Column: null Wenn die Eingabespalte true andernfalls einen Fehler mit der angegebenen Meldung auslöst.
Examples
Beispiel 1: Bestätigen einer wahren Bedingung
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|
+---+---+--------------------------------------------+
Beispiel 2: Bestätigen mit Spaltenfehlermeldung
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|
+---+---+-----------------------+
Beispiel 3: Bestätigen mit benutzerdefinierter Fehlermeldung
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|
+---+---+---------------------------+