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 2020/03/02 11:42:54 UTC

[flink] branch master updated (d9b9aad -> f0bdf31)

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 d9b9aad  [FLINK-16360][orc] Flink STRING data type should map to ORC STRING type (#11277)
     add f0bdf31  [FLINK-16007][table-planner][table-planner-blink][python] Add PythonCorrelateSplitRule to push down the Java Calls contained in Python Correlate node

No new revisions were added by this update.

Summary of changes:
 .../rules/logical/PythonCorrelateSplitRule.java    | 238 ++++++++++++++++++++
 .../planner/plan/rules/FlinkStreamRuleSets.scala   |   2 +
 .../physical/stream/StreamExecCorrelateRule.scala  |   5 +-
 .../rules/logical/PythonCorrelateSplitRuleTest.xml |  41 ++++
 ...st.scala => PythonCorrelateSplitRuleTest.scala} |  31 ++-
 .../rules/logical/PythonCorrelateSplitRule.java    | 245 +++++++++++++++++++++
 .../flink/table/plan/rules/FlinkRuleSets.scala     |   2 +
 .../flink/table/plan/util/CorrelateUtil.scala      |   5 +-
 ...st.scala => PythonCorrelateSplitRuleTest.scala} |  50 ++---
 9 files changed, 573 insertions(+), 46 deletions(-)
 create mode 100644 flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical/PythonCorrelateSplitRule.java
 create mode 100644 flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/rules/logical/PythonCorrelateSplitRuleTest.xml
 copy flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/plan/rules/logical/{SplitPythonConditionFromCorrelateRuleTest.scala => PythonCorrelateSplitRuleTest.scala} (69%)
 create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/plan/rules/logical/PythonCorrelateSplitRule.java
 copy flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/plan/{SplitPythonConditionFromCorrelateRuleTest.scala => PythonCorrelateSplitRuleTest.scala} (52%)