existe
Retorna se um predicado é verdadeiro para um ou mais elementos da matriz. Compatível com Spark Connect.
Para a função Databricks SQL correspondente, consulte a funçãoexists.
Sintaxe
Python
from pyspark.databricks.sql import functions as dbf
dbf.exists(col=<col>, f=<f>)
Parâmetros
Parâmetro | Tipo | Descrição |
|---|---|---|
|
| Nome da coluna ou expressão. |
|
| Uma função que retorna a expressão Boolean . |
Devoluções
pyspark.sql.ColumnRetorna verdadeiro se "qualquer" elemento de um array for avaliado como verdadeiro quando passado como argumento para a função fornecida e falso caso contrário.
Exemplos
Python
from pyspark.databricks.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()
Output
+------------+
|any_negative|
+------------+
| false|
| true|
+------------+