在apache flink的表api中使用case查询

fjaof16o 于 2021-06-26 发布在 Flink

关注(0)|答案(1)|浏览(677)

我正在使用flink的表api。我想用 CASE WHEN 在表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的表api可以这样做吗？如果是，怎么做？

1条答案

最新flink版本1.0.3的表api不支持 CASE WHEN 条款。
在下一个版本（flink1.1.0）中，表api经过了修改、扩展，并将支持 CASE WHEN 条款。我们可以尝试1.1快照版本来尝试该功能。感谢您的反馈。