This is an automated email from the ASF dual-hosted git repository.
hequn pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from b9f51de [hotfix][python] Clean up test_environment_completeness by
removing the legacy excluded methods which are already supported
add 22930e3 [FLINK-14022][table-planner][table-planner-blink] Add python
udf validation check in MatchRecognize
add 02bc04a [FLINK-14022][table-planner][table-planner-blink] Introduces
SplitPythonConditionFromJoinRule which splits Python Functions from join
conditions
add 84f830b [FLINK-14022][table-planner][table-planner-blink] Add python
udf validation check in join condition
No new revisions were added by this update.
Summary of changes:
.../plan/nodes/common/CommonLookupJoin.scala | 7 ++
.../plan/nodes/common/CommonPhysicalJoin.scala | 8 ++
.../nodes/physical/stream/StreamExecMatch.scala | 6 ++
.../physical/stream/StreamExecWindowJoin.scala | 7 ++
.../planner/plan/rules/FlinkBatchRuleSets.scala | 2 +
.../planner/plan/rules/FlinkStreamRuleSets.scala | 2 +
.../logical/SplitPythonConditionFromJoinRule.scala | 86 ++++++++++++++++
.../SplitPythonConditionFromJoinRuleTest.xml | 82 ++++++++++++++++
.../validation/MatchRecognizeValidationTest.scala | 24 +++++
.../plan/batch/sql/join/LookupJoinTest.scala | 17 ++++
.../table/validation/JoinValidationTest.scala | 13 ++-
... => SplitPythonConditionFromJoinRuleTest.scala} | 63 ++++++------
.../plan/stream/sql/join/WindowJoinTest.scala | 17 ++++
.../org/apache/flink/table/plan/Optimizer.scala | 2 +-
.../apache/flink/table/plan/nodes/CommonJoin.scala | 10 ++
.../plan/nodes/datastream/DataStreamJoin.scala | 2 +
.../plan/nodes/datastream/DataStreamMatch.scala | 7 ++
.../nodes/datastream/DataStreamWindowJoin.scala | 2 +
.../flink/table/plan/rules/FlinkRuleSets.scala | 3 +
.../logical/SplitPythonConditionFromJoinRule.scala | 86 ++++++++++++++++
.../utils/JavaUserDefinedScalarFunctions.java | 73 ++++++++++++++
.../stream/sql/validation/JoinValidationTest.scala | 22 +++++
.../validation/MatchRecognizeValidationTest.scala | 25 ++++-
.../table/validation/JoinValidationTest.scala | 17 ++++
.../flink/table/plan/PythonCalcSplitRuleTest.scala | 30 +-----
.../SplitPythonConditionFromJoinRuleTest.scala | 109 +++++++++++++++++++++
26 files changed, 656 insertions(+), 66 deletions(-)
create mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/logical/SplitPythonConditionFromJoinRule.scala
create mode 100644
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/rules/logical/SplitPythonConditionFromJoinRuleTest.xml
copy
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/plan/rules/logical/{FlinkCalcMergeRuleTest.scala
=> SplitPythonConditionFromJoinRuleTest.scala} (61%)
create mode 100644
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/rules/logical/SplitPythonConditionFromJoinRule.scala
create mode 100644
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/plan/SplitPythonConditionFromJoinRuleTest.scala
