spark中otherwise介绍
时间: 2023-08-12 12:10:31 浏览: 243
Spark中文分词+文本分类.rar
在Spark中,`otherwise`是Spark SQL中的一个函数,用于选择多个条件中的默认值。它通常与`when`和`otherwise`一起使用,构成一个条件表达式。`when`函数根据给定的条件进行判断,如果条件成立,则返回指定的值,否则继续判断下一个条件。如果所有条件都不成立,那么`otherwise`函数指定的默认值会被返回。
以下是一个使用`when`和`otherwise`的示例:
```scala
import org.apache.spark.sql.functions._
val df = spark
.range(1, 10)
.select(col("id"), when(col("id") % 2 === 0, "Even").otherwise("Odd").as("type"))
df.show()
```
这个示例创建了一个DataFrame,其中包含了一列'id'。使用`when`函数,我们根据'id'的奇偶性判断并给出相应的类型。如果'id'是偶数,则返回"Even",否则返回"Odd"。最后,使用`otherwise`指定了当所有条件都不满足时的默认值。
运行上述代码后,输出的DataFrame将包含两列:"id"和"type"。根据"id"的值,"type"列将显示相应的类型:"Even"或"Odd"。
总而言之,`otherwise`函数在Spark中用于选择多个条件中的默认值,并与`when`函数一起使用来构建条件表达式。
阅读全文