1. 程式人生 > >Spark sql中的case when else

Spark sql中的case when else

val dataSeq = sql("SELECT if(os.status_pay=1,1,0) " +
  " FROM OrderShopModel os ")

.collect().foreach(println)

Spark Sql因為支援Hive的UDF,所以往往復雜的SQL可以寫成很簡單的方式實現。

if(os.status_pay=1,1,0) 等價於 case os.status_pay when 1 then 1 else 0 end