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/23 07:44:51 UTC

[flink] branch master updated (46f1c44 -> 1e6c187)

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 46f1c44  [FLINK-19273][sql-parser] Support METADATA syntax in SQL parser
     add 1e6c187  [FLINK-19333][python] Introduce BatchArrowPythonOverWindowAggregateFunctionOperator

No new revisions were added by this update.

Summary of changes:
 .../pyflink/fn_execution/flink_fn_execution_pb2.py | 217 ++++++++++----
 .../pyflink/proto/flink-fn-execution.proto         |  21 ++
 ...stractArrowPythonAggregateFunctionOperator.java |   2 +-
 ...wPythonOverWindowAggregateFunctionOperator.java | 332 +++++++++++++++++++++
 ...owPythonGroupAggregateFunctionOperatorTest.java |   3 +-
 ...onGroupWindowAggregateFunctionOperatorTest.java |   3 +-
 ...onOverWindowAggregateFunctionOperatorTest.java} | 156 +++++-----
 .../PassThroughPythonAggregateFunctionRunner.java  |  45 ++-
 8 files changed, 647 insertions(+), 132 deletions(-)
 create mode 100644 flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/aggregate/arrow/batch/BatchArrowPythonOverWindowAggregateFunctionOperator.java
 copy flink-python/src/test/java/org/apache/flink/table/runtime/operators/python/aggregate/arrow/batch/{BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.java => BatchArrowPythonOverWindowAggregateFunctionOperatorTest.java} (60%)