This is an automated email from the ASF dual-hosted git repository.
hxb pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 0e25604 [FLINK-21916] Allows multiple kinds of ManagedMemoryUseCase
for the same operator
add 797b382 [FLINK-21628][python] Support Python UDAF in Tumbling Window
No new revisions were added by this update.
Summary of changes:
flink-python/pyflink/common/types.py | 6 +
.../pyflink/fn_execution/aggregate_fast.pxd | 2 -
.../pyflink/fn_execution/aggregate_fast.pyx | 14 +-
.../pyflink/fn_execution/aggregate_slow.py | 16 +-
.../fn_execution/beam/beam_coder_impl_slow.py | 35 +-
.../pyflink/fn_execution/beam/beam_coders.py | 32 +-
.../pyflink/fn_execution/beam/beam_operations.py | 23 +-
.../pyflink/fn_execution/coder_impl_fast.pxd | 7 +
.../pyflink/fn_execution/coder_impl_fast.pyx | 67 ++-
flink-python/pyflink/fn_execution/coders.py | 20 +-
.../pyflink/fn_execution/flink_fn_execution_pb2.py | 159 ++++++-
flink-python/pyflink/fn_execution/operations.py | 129 +++++-
.../pyflink/fn_execution/window_aggregate_fast.pxd | 79 ++++
.../pyflink/fn_execution/window_aggregate_fast.pyx | 494 +++++++++++++++++++++
.../pyflink/fn_execution/window_aggregate_slow.py | 453 +++++++++++++++++++
.../pyflink/fn_execution/window_assigner.py | 111 +++++
.../pyflink/fn_execution/window_context.py | 248 +++++++++++
.../fn_execution/window_process_function.py | 154 +++++++
.../pyflink/fn_execution/window_trigger.py | 212 +++++++++
.../pyflink/proto/flink-fn-execution.proto | 25 ++
flink-python/pyflink/table/tests/test_udaf.py | 116 +++++
flink-python/setup.py | 8 +
.../beam/BeamDataStreamPythonFunctionRunner.java | 4 +-
.../python/beam/BeamPythonFunctionRunner.java | 11 +-
.../AbstractPythonStatelessFunctionFlatMap.java | 3 +-
.../python/AbstractStatelessFunctionOperator.java | 3 +-
.../AbstractPythonStreamAggregateOperator.java | 33 +-
...AbstractPythonStreamGroupAggregateOperator.java | 19 +-
.../PythonStreamGroupAggregateOperator.java | 3 +-
.../PythonStreamGroupTableAggregateOperator.java | 3 +-
.../PythonStreamGroupWindowAggregateOperator.java | 83 ++--
.../BeamTableStatefulPythonFunctionRunner.java | 12 +-
.../BeamTableStatelessPythonFunctionRunner.java | 11 +-
.../table/runtime/typeutils/PythonTypeUtils.java | 9 +-
...ghPythonStreamGroupWindowAggregateOperator.java | 64 ++-
.../PassThroughPythonAggregateFunctionRunner.java | 3 +-
.../PassThroughPythonScalarFunctionRunner.java | 3 +-
.../PassThroughPythonTableFunctionRunner.java | 3 +-
...ThroughStreamAggregatePythonFunctionRunner.java | 4 +-
...amGroupWindowAggregatePythonFunctionRunner.java | 4 +-
...ghStreamTableAggregatePythonFunctionRunner.java | 4 +-
41 files changed, 2488 insertions(+), 201 deletions(-)
create mode 100644 flink-python/pyflink/fn_execution/window_aggregate_fast.pxd
create mode 100644 flink-python/pyflink/fn_execution/window_aggregate_fast.pyx
create mode 100644 flink-python/pyflink/fn_execution/window_aggregate_slow.py
create mode 100644 flink-python/pyflink/fn_execution/window_assigner.py
create mode 100644 flink-python/pyflink/fn_execution/window_context.py
create mode 100644 flink-python/pyflink/fn_execution/window_process_function.py
create mode 100644 flink-python/pyflink/fn_execution/window_trigger.py
