Not
Bu sayfaya erişim yetkilendirme gerektiriyor. Oturum açmayı veya dizinleri değiştirmeyi deneyebilirsiniz.
Bu sayfaya erişim yetkilendirme gerektiriyor. Dizinleri değiştirmeyi deneyebilirsiniz.
Giriş sütunu ise nulldöndürürtrue; aksi takdirde sağlanan hata iletisiyle bir özel durum oluşturur.
Sözdizimi
from pyspark.sql import functions as sf
sf.assert_true(col, errMsg=None)
Parametreler
| Parametre | Türü | Description |
|---|---|---|
col |
pyspark.sql.Column veya str |
Test için giriş sütununu temsil eden sütun adı veya sütunu. |
errMsg |
pyspark.sql.Column veya str, isteğe bağlı |
Hata iletisini içeren python dizesi değişmez değeri veya sütunu. |
İade
pyspark.sql.Column: null giriş sütunu true aksi takdirde belirtilen iletiyle bir hata oluşturursa.
Örnekler
Örnek 1: Doğru koşul onaylama
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|
+---+---+--------------------------------------------+
Örnek 2: Sütun hata iletisiyle onaylama
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|
+---+---+-----------------------+
Örnek 3: Özel hata iletisiyle onaylama
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|
+---+---+---------------------------+