SpassSQL with Cassandraを使用する場合のIF/Caseステートメント

Question

Scalaを使用してCassandraからSparkを選択するときにデータを変換しようとしています。

データを選択するとき、値に基づいてカウントを特定のcount_ *列に配置するようにデータを変換したいと考えています。

Spark SQLで使用するIF/CASE文が見つかりません。何か案は？

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がSparkSQLにも有効であるかどうかはわかりません。 SparkSQLがcase elseステートメントをサポートしているかどうか覚えていない。

もう一つのポイントは、COUNT(*)とSUM(...)が集計関数であり、彼らは唯一のあなたの声明

に欠けている GROUP BY句、と連携して働くことができるということです