在 Apache Flink 的 Table API 中使用 CASE WHEN 进行查询

Question

我正在使用Flink的Table API。我希望在表API查询中使用CASE WHEN。我的查询使用三个字段：routeid, startlocation, distance和我想使用CASE WHEN子句来识别基于distance值的因素，这些因素是基于routeid需要满足的条件。

示例：

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

使用Flink的Table API，这可能吗？如果是，该怎么办？

Answer 1

最新Flink 1.0.3版本的Table API不支持CASE WHEN子句。

对于下一个版本（Flink 1.1.0），表API将被重新编写、扩展，并将支持CASE WHEN子句。我们可以尝试1.1-SNAPSHOT版本来尝试该功能。感谢反馈。