forall

Devuelve si un predicado se cumple para cada elemento del array. Soporta Spark Connect.

Para obtener la función SQL de Databricks correspondiente, consulte forall function.

Syntax

from pyspark.sql import functions as dbf

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

Parámetros

Parámetro	Tipo	Description
col	pyspark.sql.Column o str	Nombre de columna o expresión.
f	function	Función que devuelve la expresión booleana.

Devoluciones

pyspark.sql.Column: true si los elementos "all" de una matriz se evalúan como True cuando se pasan como argumento a una función determinada y False de lo contrario.

Examples

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