spark sql equalTo
时间: 2023-10-21 21:06:54 浏览: 133
`equalTo` 是 Spark SQL 中用于比较两个表达式是否相等的函数。它返回一个布尔值,如果两个表达式相等,则为 true,否则为 false。
例如,以下代码将创建一个 DataFrame,并使用 `equalTo` 函数比较两个列是否相等:
```scala
import org.apache.spark.sql.functions._
val df = Seq((1, "foo"), (2, "bar"), (3, "baz")).toDF("id", "value")
df.select(col("id"), col("value"), equalTo(col("id"), col("value")) as "equal").show()
```
输出结果为:
```
+---+-----+-----+
| id|value|equal|
+---+-----+-----+
| 1| foo|false|
| 2| bar|false|
| 3| baz|false|
+---+-----+-----+
```
可以看到,由于 `id` 和 `value` 列的值不相等,因此 `equalTo` 函数返回了 false。
阅读全文