assert_true

Mengembalikan null jika kolom input adalah true; melemparkan pengecualian dengan pesan kesalahan yang disediakan sebaliknya.

Syntax

from pyspark.sql import functions as sf

sf.assert_true(col, errMsg=None)

Parameter-parameternya

Pengaturan	Tipe	Description
col	pyspark.sql.Column atau str	Nama kolom atau kolom yang mewakili kolom input untuk diuji.
errMsg	pyspark.sql.Column atau str, opsional	String Python literal atau kolom yang berisi pesan kesalahan.

Pengembalian Barang

pyspark.sql.Column: null jika kolom input sebaliknya true melemparkan kesalahan dengan pesan yang ditentukan.

Examples

Contoh 1: Menegaskan kondisi yang sebenarnya

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

Contoh 2: Menegaskan dengan pesan kesalahan kolom

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

Contoh 3: Menegaskan dengan pesan kesalahan kustom

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