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/10/23 05:57:18 UTC
[flink] branch master updated (5135cea -> ae043e0)

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 5135cea  [FLINK-13539][table-api] Improve CSV table factory doesn't need to require format.fields
     add ae043e0  [FLINK-14202][table][python] Optimize the execution plan for Python Calc when there is a condition

No new revisions were added by this update.

Summary of changes:
 flink-python/pyflink/table/tests/test_udf.py       |  10 +-
 .../plan/nodes/common/CommonPythonCalc.scala       |  95 +-----
 .../nodes/physical/batch/BatchExecPythonCalc.scala |  13 +-
 .../physical/stream/StreamExecPythonCalc.scala     |  21 +-
 .../planner/plan/rules/FlinkBatchRuleSets.scala    |   5 +-
 .../planner/plan/rules/FlinkStreamRuleSets.scala   |   5 +-
 .../plan/rules/logical/PythonCalcSplitRule.scala   | 322 +++++++++++++++++++++
 .../logical/PythonScalarFunctionSplitRule.scala    | 210 --------------
 .../plan/rules/logical/PythonCalcSplitRuleTest.xml | 235 +++++++++++++++
 .../logical/PythonScalarFunctionSplitRuleTest.xml  | 164 -----------
 ...uleTest.scala => PythonCalcSplitRuleTest.scala} |  16 +-
 .../flink/table/plan/nodes/CommonPythonCalc.scala  |   3 +-
 .../nodes/datastream/DataStreamPythonCalc.scala    |  54 +---
 .../flink/table/plan/rules/FlinkRuleSets.scala     |   5 +-
 .../plan/rules/logical/PythonCalcSplitRule.scala   | 322 +++++++++++++++++++++
 .../logical/PythonScalarFunctionSplitRule.scala    | 211 --------------
 .../table/plan/ExpressionReductionRulesTest.scala  |  11 +-
 ...uleTest.scala => PythonCalcSplitRuleTest.scala} |  78 ++++-
 18 files changed, 1006 insertions(+), 774 deletions(-)
 create mode 100644 flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/logical/PythonCalcSplitRule.scala
 delete mode 100644 flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/logical/PythonScalarFunctionSplitRule.scala
 create mode 100644 flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/rules/logical/PythonCalcSplitRuleTest.xml
 delete mode 100644 flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/rules/logical/PythonScalarFunctionSplitRuleTest.xml
 rename flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/plan/rules/logical/{PythonScalarFunctionSplitRuleTest.scala => PythonCalcSplitRuleTest.scala} (91%)
 create mode 100644 flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/rules/logical/PythonCalcSplitRule.scala
 delete mode 100644 flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/rules/logical/PythonScalarFunctionSplitRule.scala
 rename flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/plan/{PythonScalarFunctionSplitRuleTest.scala => PythonCalcSplitRuleTest.scala} (79%)