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%)
