This is an automated email from the ASF dual-hosted git repository.
hequn pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from a86387b [FLINK-18943][python] Rename AbstractPythonFunctionOperator
to AbstractOneInputPythonFunctionOperator
add ecc3429 [FLINK-18945][python] Support CoFlatMap for Python DataStream
API (#13152)
No new revisions were added by this update.
Summary of changes:
flink-python/pyflink/datastream/data_stream.py | 38 ++++++++++++++--
flink-python/pyflink/datastream/functions.py | 53 +++++++++++++++++++++-
.../pyflink/datastream/tests/test_data_stream.py | 44 +++++++++++++++++-
.../pyflink/fn_execution/operation_utils.py | 8 ++++
4 files changed, 136 insertions(+), 7 deletions(-)
