Apache FlinkのテーブルAPIでCASE WHENを使用するクエリ

Question

私はFlinkのテーブルAPIを使用しています。テーブルAPIクエリでCASE WHENを使用したいと思います。 私のクエリでは、routeid, startlocation, distanceという3つのフィールドが使用されており、routeidに基づいて満足するために必要な条件であるdistanceの値に基づいて要因を特定するのにCASE WHEN句を使用します。

例：

SELECT 
    routeid, 
    startlocation, 
    CASE WHEN (routeid=1) AND (distance > 0 AND distance <= 250) THEN 'oneday-distance' 

はFLINKのテーブルAPIでこれは可能ですか？はいの場合、どうすればできますか？

Answer 1

最新のFlinkバージョン1.0.3のテーブルAPIはCASE WHENをサポートしていません。

次のリリース（Flink 1.1.0）では、テーブルAPIが再作成され、拡張され、CASE WHEN句をサポートします。 1.1-SNAPSHOTバージョンを試してみてください。フィードバックは高く評価されます。