forall

Restituisce se un predicato si verifica per ogni elemento dell'array. Supporta Spark Connect.

Per la funzione SQL di Databricks corrispondente, vedere forall funzione.

Sintassi

from pyspark.databricks.sql import functions as dbf

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

Parametri

Parametro	TIPO	Description
col	pyspark.sql.Column o str	Nome della colonna o dell'espressione.
f	function	Funzione che restituisce l'espressione booleana.

Restituzioni

pyspark.sql.Column: True se "all" elementi di una matrice restituisce True quando viene passato come argomento alla funzione specificata e False in caso contrario.

Esempi

from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame(
    [(1, ["bar"]), (2, ["foo", "bar"]), (3, ["foobar", "foo"])],
    ("key", "values")
)
df.select(dbf.forall("values", lambda x: x.rlike("foo")).alias("all_foo")).show()

+-------+
|all_foo|
+-------+
|  false|
|  false|
|   true|
+-------+