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/24 07:54:02 UTC

[flink] branch master updated (da80206 -> 51368b8)

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 da80206  [FLINK-18737][docs-zh] Translate jdbc connector page
     add 51368b8  [FLINK-19364][python] Add Batch Physical Pandas Group Window Aggregate Rule and RelNode

No new revisions were added by this update.

Summary of changes:
 .../pyflink/table/tests/test_pandas_udaf.py        |  95 +++++++++
 ...PythonGroupWindowAggregateFunctionOperator.java |   9 +-
 ...ava => BatchExecPythonWindowAggregateRule.java} |  84 +++++---
 ...a => BatchExecPythonGroupWindowAggregate.scala} | 226 ++++++++++-----------
 .../planner/plan/rules/FlinkBatchRuleSets.scala    |   1 +
 .../batch/BatchExecWindowAggregateRule.scala       |   3 +-
 .../batch/table/PythonGroupWindowAggregateTest.xml |  73 +++++++
 .../table/PythonGroupWindowAggregateTest.scala     | 104 ++++++++++
 8 files changed, 453 insertions(+), 142 deletions(-)
 copy flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/physical/batch/{BatchExecPythonAggregateRule.java => BatchExecPythonWindowAggregateRule.java} (58%)
 copy flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/{BatchExecPythonGroupAggregate.scala => BatchExecPythonGroupWindowAggregate.scala} (51%)
 create mode 100644 flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/batch/table/PythonGroupWindowAggregateTest.xml
 create mode 100644 flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/plan/batch/table/PythonGroupWindowAggregateTest.scala