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

Question

我正在使用 Flink 的 Table API。我想在 Table 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)，Table API 进行了重新设计和扩展，并将支持 CASE WHEN 子句。我们可以尝试1.1-SNAPSHOT版本来尝试该功能。欢迎提供反馈。