Udostępnij przez


istnieje

Zwraca, czy predykat jest spełniony dla jednego lub więcej elementów w tablicy. Obsługuje program Spark Connect.

Aby uzyskać odpowiednią funkcję SQL usługi Databricks, zobacz exists funkcja.

Składnia

from pyspark.databricks.sql import functions as dbf

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

Parametry

Parameter Typ Description
col pyspark.sql.Column lub str Nazwa kolumny lub wyrażenia.
f function Funkcja zwracająca wyrażenie logiczne.

Zwraca

pyspark.sql.Column: prawda, jeśli element "dowolny" tablicy zwraca wartość True, gdy przekazano jako argument do danej funkcji i w przeciwnym razie wartość False.

Przykłady

from pyspark.databricks.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|
+------------+