forall

配列内のすべての要素に対して述語が成り立つかどうかを返します。Spark Connect をサポートします。

対応する Databricks SQL 関数については、 forall関数を参照してください。

構文

Python

from pyspark.databricks.sql import functions as dbf

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

パラメーター

パラメーター	Type	説明
col	pyspark.sql.Column または str	列または式の名前。
f	function	Boolean式を返す関数。

戻り値

pyspark.sql.Column: 指定された関数に引数として渡されたときに、配列の「すべての」要素が True と評価される場合は True、それ以外の場合は False になります。

例

Python

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()

Output

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