배열의 하나 이상의 요소가 조건을 충족하는지 여부를 반환합니다. Spark Connect를 지원합니다.
해당 Databricks SQL 함수에 대해 알아보려면 exists 함수를 참조하세요.
문법
from pyspark.sql import functions as dbf
dbf.exists(col=<col>, f=<f>)
매개 변수
| 매개 변수 | 유형 | Description |
|---|---|---|
col |
pyspark.sql.Column 또는 str |
열 또는 식의 이름입니다. |
f |
function |
부울 식을 반환하는 함수입니다. |
Returns
pyspark.sql.Column: 지정된 함수에 인수로 전달될 때 배열의 "any" 요소가 True로 계산되고 그렇지 않으면 False이면 True입니다.
예시
from pyspark.sql import functions as dbf
df = spark.createDataFrame([(1, [1, 2, 3, 4]), (2, [3, -1, 0])],("key", "values"))
df.select(dbf.exists("values", lambda x: x < 0).alias("any_negative")).show()
+------------+
|any_negative|
+------------+
| false|
| true|
+------------+