배열의 모든 요소에 대해 술어가 유효한지를 반환합니다. Spark Connect를 지원합니다.
해당 Databricks SQL 함수에 대해 알아보려면 forall 함수를 참조하세요.
문법
from pyspark.sql import functions as dbf
dbf.forall(col=<col>, f=<f>)
매개 변수
| 매개 변수 | 유형 | Description |
|---|---|---|
col |
pyspark.sql.Column 또는 str |
열 또는 식의 이름입니다. |
f |
function |
부울 식을 반환하는 함수입니다. |
Returns
pyspark.sql.Column: 지정된 함수에 인수로 전달될 때 배열의 "all" 요소가 True로 계산되고 그렇지 않으면 False이면 True입니다.
예시
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|
+-------+