mevcut

Bir önermenin, dizideki bir veya daha fazla öğe için geçerli olup olmadığını döndürür. Spark Connect'i destekler.

İlgili Databricks SQL fonksiyonu için bakınız exists fonksiyonu.

Sözdizimi

from pyspark.sql import functions as dbf

dbf.exists(col=<col>, f=<f>)

Parametreler

Parametre	Türü	Description
col	pyspark.sql.Column veya str	Sütun veya ifadenin adı.
f	function	Boole ifadesini döndüren bir işlev.

İade

pyspark.sql.Column: Bir dizinin "herhangi bir" öğesi, verilen işleve bağımsız değişken olarak geçirildiğinde True olarak değerlendirilirse true, aksi takdirde False olarak değerlendirilir.

Örnekler

from pyspark.sql import functions as dbf
df = spark.createDataFrame([(1, [1, 2, 3, 4]), (2, [3, -1, 0])],("key", "values"))
df.select(dbf.exists("values", lambda x: x < 0).alias("any_negative")).show()

+------------+
|any_negative|
+------------+
|       false|
|        true|
+------------+