在Select子句中Flink表API条件

Question

一个相关的旧邮件列表：链接

Flink Table API条件函数文档：链接

示例：

table.select($("apple").isNotNull()
? $("apple").as("fruit")
: $("pear").as("fruit"));

$("apple"(.isNotNull((返回一个ApiExpression，而不是布尔表达式。

有人用API表做过类似的事情吗？

Answer 1

使用Table API，您只是在构建一个稍后将执行的表达式。所以所有的表达式只返回另一个表达式，从而构建一个表达式树。在SQL中使用org.apache.flink.table.api.Expressions#ifThenElse或CASE WHEN END。