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 662cec6 [FLINK-18122][e2e] Make K8s test more resilient by retrying
and failing docker image build (2nd try)
add 2dc872a [FLINK-19235][python] Support mixed use of built-in aggs with
Python UDAF
No new revisions were added by this update.
Summary of changes:
flink-python/pyflink/fn_execution/aggregate.py | 60 ++++++---
.../pyflink/fn_execution/flink_fn_execution_pb2.py | 83 ++++++------
.../pyflink/fn_execution/operation_utils.py | 22 +++-
flink-python/pyflink/fn_execution/operations.py | 18 +--
.../pyflink/proto/flink-fn-execution.proto | 2 +
flink-python/pyflink/table/functions.py | 146 ++++++++++++++++++++-
flink-python/pyflink/table/table_result.py | 2 +-
flink-python/pyflink/table/tests/test_aggregate.py | 44 ++++++-
.../table/tests/test_table_environment_api.py | 20 +--
.../PythonStreamGroupAggregateOperator.java | 8 ++
.../PythonStreamGroupAggregateOperatorTest.java | 3 +
.../python/BuiltInPythonAggregateFunction.java | 63 +++++++++
.../python/PythonAggregateFunctionInfo.java | 13 --
.../stream/StreamExecPythonGroupAggregateRule.java | 7 +-
.../plan/nodes/common/CommonPythonAggregate.scala | 42 +++++-
.../stream/StreamExecPythonGroupAggregate.scala | 10 +-
.../table/planner/plan/utils/PythonUtil.scala | 12 ++
.../plan/stream/table/PythonAggregateTest.xml | 16 +++
.../plan/stream/table/PythonAggregateTest.scala | 2 +-
19 files changed, 463 insertions(+), 110 deletions(-)
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/python/BuiltInPythonAggregateFunction.java
