You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by he...@apache.org on 2019/11/01 15:30:32 UTC
[flink] branch master updated (b9f51de -> 84f830b)
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