2017-01-23 33 views
1

我试图实现低于甲骨文的逻辑火花1.5.0功能,我有这样甲骨文NVL,而不是在火花SQL

防爆选择查询:

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 

我想在火花中实现案例和NVL逻辑有人可以帮助我如何通过使用数据框在火花scala API中实现此逻辑。

+0

NVL功能在Spark中支持。就Exists而言,不涉及这一点。 –

+0

@RajatMishra您能否指出Spark SQL中支持哪些NVL函数。我现在花了30米,想尽一切办法找到说明如何使用它们的文档。 – chaotic3quilibrium

回答

-1

DF: ID,描述,值 1, “东西”, “它的存在” 2, “无”,空

SQL: 选择ID,描述,NVL(值, 'N' )来自df;

结果: ID,描述,值 1, '的东西', '它的存在' 2, '无',在火花 'N'

测试2.1.0