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 1fc400d [FLINK-18879][python] Support Row Serialization and Deserialization schemas for Python DataStream API. (#13150) add 175038b [FLINK-18943][python] Support CoMapFunction for Python DataStream API add a86387b [FLINK-18943][python] Rename AbstractPythonFunctionOperator to AbstractOneInputPythonFunctionOperator No new revisions were added by this update. Summary of changes: flink-python/dev/glibc_version_fix.h | 0 flink-python/pyflink/datastream/data_stream.py | 105 ++++++++++++++++++++- flink-python/pyflink/datastream/functions.py | 35 +++++++ .../pyflink/datastream/tests/test_data_stream.py | 38 ++++++++ .../pyflink/fn_execution/flink_fn_execution_pb2.py | 90 ++++++++++-------- .../pyflink/fn_execution/operation_utils.py | 6 ++ .../pyflink/proto/flink-fn-execution.proto | 2 + .../DataStreamPythonStatelessFunctionOperator.java | 5 +- ...amTwoInputPythonStatelessFunctionOperator.java} | 87 +++++++++++------ .../AbstractOneInputPythonFunctionOperator.java | 23 ++--- ...ava => AbstractPythonFunctionOperatorBase.java} | 18 +--- .../AbstractTwoInputPythonFunctionOperator.java | 26 ++--- .../python/AbstractStatelessFunctionOperator.java | 4 +- 13 files changed, 326 insertions(+), 113 deletions(-) mode change 100644 => 100755 flink-python/dev/glibc_version_fix.h copy flink-python/src/main/java/org/apache/flink/datastream/runtime/operators/python/{DataStreamPythonStatelessFunctionOperator.java => DataStreamTwoInputPythonStatelessFunctionOperator.java} (62%) copy flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/data/conversion/DayTimeIntervalDurationConverter.java => flink-python/src/main/java/org/apache/flink/streaming/api/operators/python/AbstractOneInputPythonFunctionOperator.java (58%) rename flink-python/src/main/java/org/apache/flink/streaming/api/operators/python/{AbstractPythonFunctionOperator.java => AbstractPythonFunctionOperatorBase.java} (95%) copy flink-java/src/main/java/org/apache/flink/api/java/functions/FormattingMapper.java => flink-python/src/main/java/org/apache/flink/streaming/api/operators/python/AbstractTwoInputPythonFunctionOperator.java (57%)