flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From he...@apache.org
Subject [flink] branch master updated (b9f51de -> 84f830b)
Date Fri, 01 Nov 2019 15:30:32 GMT
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


Mime
View raw message