小编pra*_*een的帖子

如何使用scala在spark sql中使用条件时写入case

SELECT c.PROCESS_ID, 
       CASE WHEN c.PAYMODE = 'M' 
           THEN 
               CASE WHEN CURRENCY = 'USD' 
                   THEN c.PREMIUM * c.RATE 
                   ELSE c.PREMIUM END * 12
           ELSE 
               CASE WHEN CURRENCY = 'USD' 
                   THEN c.PREMIUM * c.RATE 
                   ELSE c.PREMIUM END END VAlue
FROM CMM c
Run Code Online (Sandbox Code Playgroud)

我想转换sql查询spark sql api我该怎么办?

谢谢

apache-spark-sql

17
推荐指数
1
解决办法
3万
查看次数

标签 统计

apache-spark-sql ×1