Cassandra ile SparkSQL kullanırken IF/Case deyimi

Question

Scala kullanarak Cassandra'dan Spark'e seçim yaparken verileri dönüştürmeye çalışıyorum.

Veri seçerken, verileri, sayıları esas alarak belirli bir count_ * sütununa yerleştirmek için verileri dönüştürmek istiyorum.

Spark SQL ile kullanmak için bir IF/CASE deyimi bulamıyorum. Herhangi bir fikir?

val results = csc.sql(" 
    SELECT trip_sell_key, trip_veh_key, idle_stop_date, COUNT(*), 
    SUM (case when idle_stop_duration >= 0 
    and idle_stop_duration < 5 then 1 else 0 end) 
    from veh_trip" 
) 

Answer 1

SQL'in SparkSQL için geçerli olduğundan emin bile değilim. SparkSQL'in case else ifadelerini destekleyip desteklemediğini hatırlama.

başka nokta COUNT(*) ve SUM(...) toplama işlevleri olduğunu ve onlar sadece açıklamada eksik bir GROUP BY maddesi ile bağlantılı olarak çalışabilir