You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by di...@apache.org on 2020/09/18 05:03:25 UTC

[flink] branch master updated (49e3ff7 -> da86aee)

This is an automated email from the ASF dual-hosted git repository.

dianfu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 49e3ff7  [FLINK-19262][API/DataStream] Can not setParallelism for FLIP-27 source
     add da86aee  [FLINK-19184][python] Introduce BatchExecPythonAggregateRule and BatchExecPythonGroupAggregate

No new revisions were added by this update.

Summary of changes:
 .../batch/BatchExecPythonAggregateRule.java        | 137 +++++++++++++++++++++
 ...e.scala => BatchExecPythonGroupAggregate.scala} |  85 +++++++------
 .../planner/plan/rules/FlinkBatchRuleSets.scala    |   1 +
 .../physical/batch/BatchExecHashAggRule.scala      |   4 +-
 .../physical/batch/BatchExecSortAggRule.scala      |   5 +-
 .../table/planner/plan/utils/PythonUtil.scala      |  21 +++-
 .../runtime/utils/JavaUserDefinedAggFunctions.java |  24 ++++
 .../plan/batch/table/PythonAggregateTest.xml       |  52 ++++++++
 ...honCalcTest.scala => PythonAggregateTest.scala} |  32 +++--
 9 files changed, 309 insertions(+), 52 deletions(-)
 create mode 100644 flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/physical/batch/BatchExecPythonAggregateRule.java
 copy flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/{BatchExecSortAggregate.scala => BatchExecPythonGroupAggregate.scala} (75%)
 create mode 100644 flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/batch/table/PythonAggregateTest.xml
 copy flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/plan/batch/table/{PythonCalcTest.scala => PythonAggregateTest.scala} (59%)