This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from e8c1d1b9d41 [FLINK-35963][table] Add the built-in function
REGEXP_SUBSTR
add 9ecf4cf405c [FLINK-35716] Adds a rule which splits out async calls
from join conditions
No new revisions were added by this update.
Summary of changes:
.../plan/rules/logical/AsyncCalcSplitRule.java | 6 +
.../planner/plan/rules/FlinkStreamRuleSets.scala | 2 +
.../logical/SplitPythonConditionFromJoinRule.scala | 67 +----
...cala => SplitRemoteConditionFromJoinRule.scala} | 44 ++--
.../plan/rules/logical/AsyncCalcSplitRuleTest.java | 93 +++++++
.../runtime/stream/table/AsyncCalcITCase.java | 24 ++
.../plan/rules/logical/AsyncCalcSplitRuleTest.xml | 276 +++++++++++++++++++++
7 files changed, 434 insertions(+), 78 deletions(-)
copy
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/rules/logical/{SplitPythonConditionFromJoinRule.scala
=> SplitRemoteConditionFromJoinRule.scala} (64%)
