Airblader commented on a change in pull request #17256:
URL: https://github.com/apache/flink/pull/17256#discussion_r707178396
##########
File path:
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/Expressions.java
##########
@@ -535,6 +535,18 @@ public static ApiExpression ifThenElse(Object condition,
Object ifTrue, Object i
return apiCall(BuiltInFunctionDefinitions.IF, condition, ifTrue,
ifFalse);
}
+ /**
+ * Coalesce specifies a series of expressions, and returns the first
expression whose value is
+ * not null. If all the expressions evaluate as null, coalesce returns a
null value.
+ *
+ * <p>e.g. coalesce($("f0"), "-") leads to "-" if f0 is null
+ *
+ * @param args the input expressions.
+ */
+ public static ApiExpression coalesce(Object... args) {
Review comment:
We'll also need to add this for the Scala API
(ImplicitExpressionConversions).
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
