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 da75a90 [FLINK-19700][k8s] Make Kubernetes Client in
KubernetesResourceManagerDriver use io executor
add 4e4b655 [FLINK-19412][python] Refactor Python operation to eliminate
code duplication
No new revisions were added by this update.
Summary of changes:
.../pyflink/fn_execution/beam/beam_operations.py | 127 ++++++
.../fn_execution/beam/beam_operations_fast.pxd | 31 +-
.../fn_execution/beam/beam_operations_fast.pyx | 412 ++------------------
.../fn_execution/beam/beam_operations_slow.py | 433 ++-------------------
.../fn_execution/beam/beam_sdk_worker_main.py | 5 +-
.../beam_operations_slow.py => operations.py} | 231 ++---------
6 files changed, 237 insertions(+), 1002 deletions(-)
create mode 100644 flink-python/pyflink/fn_execution/beam/beam_operations.py
copy flink-python/pyflink/fn_execution/{beam/beam_operations_slow.py =>
operations.py} (61%)
