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

Question

我正在使用 Flink 的 Table API。我想CASE WHEN在 Table API 查询中使用。我的查询使用三个字段：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），Table API 进行了重新设计、扩展，并将支持CASE WHEN子句。我们可以试试 1.1-SNAPSHOT 版本来试试这个功能。反馈表示赞赏。