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