我正在尝试在spark 1.5.0中实现下面的oracle逻辑,我有如下select查询select name, id, age, country, CASE WHEN (id is not我想在spark中实现case和NVL逻辑,有人可以帮助我如何使用数据帧在sparkscala API中实现这个逻辑吗?
我正在使用hadoop 3.0.0和spark 2.2.0中的以下scala代码处理数据帧。BAQ是ID列,AAA是日期YYMMDD的字符串列。scala> val dtfAbnoFirs=dtfAbno.filter("AAA>='20201201' and BAQ<>'0'").org.apache.spark.