existuje

Vrátí, zda predikát obsahuje jeden nebo více prvků v poli. Podporuje Spark Connect.

Odpovídající funkci SQL Databricks vizte funkceexists.

Syntaxe

from pyspark.sql import functions as dbf

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

Parametry

Parameter	Typ	Description
col	pyspark.sql.Column nebo str	Název sloupce nebo výrazu
f	function	Funkce, která vrátí logický výraz.

Návraty

pyspark.sql.Column: True, pokud "any" element pole se vyhodnotí jako True při předání jako argument pro danou funkci a False jinak.

Examples

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