slinkydeveloper commented on a change in pull request #17256:
URL: https://github.com/apache/flink/pull/17256#discussion_r712319289
##########
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 with a broader predicate support and returning a boolean.
+ */
+ def hasOperatorCallMatching(expr: RexNode, predicate:
Predicate[SqlOperator]): Boolean = {
Review comment:
Because we don't use scala-java8-compat, I did this, let me know if you
have alternatives
--
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
