提交 da10a9b5 编写于 作者: Z Zhuoluo Yang 提交者: Kurt Young

[FLINK-6068] [table] Support If() as a built-in function.

This cloes #3553.
上级 85070df1
......@@ -161,6 +161,7 @@ object FunctionCatalog {
"isFalse" -> classOf[IsFalse],
"isNotTrue" -> classOf[IsNotTrue],
"isNotFalse" -> classOf[IsNotFalse],
"if" -> classOf[If],
// aggregate functions
"avg" -> classOf[Avg],
......
......@@ -154,6 +154,11 @@ class ScalarOperatorsTest extends ExpressionTestBase {
"true.?(true.?(true.?(10, 4), 4), 4)",
"10")
testTableApi(true, "?((f6 && true), 'true', 'false')", "true")
testTableApi(
If('f9 > 'f8, 'f9 - 1, 'f9),
"If(f9 > f8, f9 - 1, f9)",
"9"
)
testSqlApi("CASE 11 WHEN 1 THEN 'a' ELSE 'b' END", "b")
testSqlApi("CASE 2 WHEN 1 THEN 'a' ELSE 'b' END", "b")
testSqlApi(
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册