slinkydeveloper commented on a change in pull request #17256:
URL: https://github.com/apache/flink/pull/17256#discussion_r712299693
##########
File path:
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/utils/FlinkRexUtil.scala
##########
@@ -535,6 +534,29 @@ object FlinkRexUtil {
throw new IllegalArgumentException(s"Unknown expression type
'${expr.getClass}': $expr")
}
}
+
+ /**
+ * Similar to [[RexUtil#findOperatorCall(SqlOperator, RexNode)]] but for
flink's udf.
+ */
+ def hasUdfInvocation(expr: RexNode, functionName: String): Boolean = {
Review comment:
I generalized a bit this function, using the `BuiltInFunctionDefinition`
concept here seems a bit odd and too specialized. Check it out now
--
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
