forall
Indique si un prédicat est vrai pour chaque élément du tableau. Prend en charge Spark Connect.
Pour la fonction Databricks SQL correspondante, consultez la fonctionforall.
Syntaxe
Python
from pyspark.sql import functions as dbf
dbf.forall(col=<col>, f=<f>)
parameter
parameter | Type | Description |
|---|---|---|
|
| Nom de la colonne ou de l'expression. |
|
| Une fonction qui renvoie l'expression booléenne. |
Renvoie
pyspark.sql.Column: True si "tous" les éléments d'un tableau évaluent à True lorsqu'ils sont passés comme argument à la fonction donnée et False sinon.
Exemples
Python
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()
Output
+-------+
|all_foo|
+-------+
| false|
| false|
| true|
+-------+