select子句中的flink表api条件

efzxgjgh  于 2021-06-21  发布在  Flink
关注(0)|答案(1)|浏览(525)

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

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

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

9o685dep

9o685dep1#

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

相关问题