我尝试在sparksql中完成大部分工作,所以我尝试使用sparksql来找出一个解决方案。
我试图实现的目标是:当src\u column2='hello'时,将target\u column加载为src\u column1,否则将target\u column=0.00
所以我试过了,但它加载的列为null,因为条件不满足:
(SELECT FIRST(IFNULL(Src_Column1, '0.00'))
FROM dfLookup Src_Table_1
WHERE Src_Column2 = 'Hello')
AS Target_Column
任何帮助都将不胜感激。
暂无答案!
目前还没有任何答案,快来回答吧!