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/09/26 06:52:21 UTC
[flink] branch master updated (ca56b63 -> 2b608e3)

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 ca56b63  [FLINK-14114][client] Shift down ClusterClient#timeout to RestClusterClient
     add 2b608e3  [FLINK-14016][python][flink-table-planner] Introduce DataStreamPythonCalc for Python function execution

No new revisions were added by this update.

Summary of changes:
 .../flink/table/functions/FunctionDefinition.java  |   7 +
 .../{FunctionKind.java => FunctionLanguage.java}   |  16 +-
 .../apache/flink/table/calcite/CalciteConfig.scala |  31 +++
 .../org/apache/flink/table/plan/Optimizer.scala    |  39 ++++
 .../apache/flink/table/plan/StreamOptimizer.scala  |   4 +-
 .../apache/flink/table/plan/nodes/CommonCalc.scala |   1 -
 .../table/plan/nodes/dataset/DataSetCalc.scala     |   1 -
 .../plan/nodes/datastream/DataStreamCalc.scala     |  43 +---
 .../DataStreamCalcBase.scala}                      |  67 +-----
 ...wAggregate.scala => DataStreamPythonCalc.scala} |  65 +++---
 .../flink/table/plan/rules/FlinkRuleSets.scala     |  10 +-
 .../plan/rules/datastream/DataStreamCalcRule.scala |  15 +-
 ...lcRule.scala => DataStreamPythonCalcRule.scala} |  25 ++-
 .../logical/PythonScalarFunctionSplitRule.scala    | 211 ++++++++++++++++++
 .../apache/flink/table/plan/util/PythonUtil.scala  |  68 ++++++
 .../table/calcite/CalciteConfigBuilderTest.scala   |  55 +++++
 .../plan/PythonScalarFunctionSplitRuleTest.scala   | 238 +++++++++++++++++++++
 17 files changed, 743 insertions(+), 153 deletions(-)
 copy flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/{FunctionKind.java => FunctionLanguage.java} (85%)
 copy flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/{dataset/DataSetCalc.scala => datastream/DataStreamCalcBase.scala} (51%)
 copy flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/datastream/{DataStreamGroupWindowAggregate.scala => DataStreamPythonCalc.scala} (55%)
 copy flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/rules/datastream/{DataStreamCalcRule.scala => DataStreamPythonCalcRule.scala} (69%)
 create mode 100644 flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/rules/logical/PythonScalarFunctionSplitRule.scala
 create mode 100644 flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/util/PythonUtil.scala
 create mode 100644 flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/plan/PythonScalarFunctionSplitRuleTest.scala