mysql-在apacheflink的表API中使用CASE query


0

我使用的是Flink的表API。我想在表API query中使用CASE。

例子:

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

用Flink的Table API可以吗?如果是,怎么办?

1 答案


0

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

在下一个版本(flink1.1.0)中,表API将被重写、扩展,并将支持CASE WHEN子句。我们可以尝试1.1快照版本来尝试该功能。感谢反馈。


我来回答

写文章

提问题

面试题