我使用的是Flink的表API。我想在表API query中使用CASE。
例子:
SELECT
routeid,
startlocation,
CASE WHEN (routeid=1) AND (distance > 0 AND distance <= 250) THEN 'oneday-distance'
用Flink的Table API可以吗?如果是,怎么办?
我使用的是Flink的表API。我想在表API query中使用CASE。
例子:
SELECT
routeid,
startlocation,
CASE WHEN (routeid=1) AND (distance > 0 AND distance <= 250) THEN 'oneday-distance'
用Flink的Table API可以吗?如果是,怎么办?
Flink最新版本1.0.3的表API不支持CASE WHEN子句。
在下一个版本(flink1.1.0)中,表API将被重写、扩展,并将支持CASE WHEN子句。我们可以尝试1.1快照版本来尝试该功能。感谢反馈。