select子句中的flink表api条件

efzxgjgh 于 2021-06-21 发布在 Flink

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

相关的旧邮件列表：链接
flink表api条件函数文档：link
例子：

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

$（“apple”）.isnotnull（）返回一个非布尔表达式。
有人用表api做过类似的尝试吗？

1条答案

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