Oracle NVL 而不是 Spark SQL 中的函数

Question

我正在尝试在 Spark 1.5.0 中实现以下 oracle 逻辑，我选择了这样的查询

前任：

select name, id, age, country, CASE WHEN (id is not null AND NVL(country,'DUMMY') NOT IN (us,'DUMMY') )
THEN correct 
ELSE wrong
END Code(one of the column)
from employee

.

我想在 Spark 中实现案例和 NVL 逻辑 有人可以帮助我如何使用数据帧在 Spark scala API 中实现此逻辑吗？

Answer 1

df：id，描述，值1，"某物"，"它在那里"2，"无"，空

.sql：从 df 中选择 id，description，nvl（值，'N'）;

结果：id，描述，值1，"某物"，"它就在那里"2，"无"，"N"

在 Spark 2.1.0 中进行测试