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 eee0d8e [FLINK-19727][table] Implement ParallelismProvider for sink
in blink planner
add dc0c5b5 [FLINK-19235][python] Support mixed use with most built-in
aggs for Python UDAF
No new revisions were added by this update.
Summary of changes:
flink-python/pyflink/table/functions.py | 674 ++++++++++++++++++++-
flink-python/pyflink/table/tests/test_aggregate.py | 57 +-
.../python/BuiltInPythonAggregateFunction.java | 16 +-
.../plan/nodes/common/CommonPythonAggregate.scala | 28 +
4 files changed, 744 insertions(+), 31 deletions(-)
