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 2333d48 [FLINK-18848][python] Fix to_pandas to handle retraction data
properly
add 240a1e8 [FLINK-18883][python] Support reduce() operation for Python
KeyedStream. (#13113)
No new revisions were added by this update.
Summary of changes:
flink-python/pyflink/datastream/data_stream.py | 77 ++++++++++---
flink-python/pyflink/datastream/functions.py | 52 +++++++++
.../pyflink/datastream/tests/test_data_stream.py | 11 ++
.../pyflink/fn_execution/flink_fn_execution_pb2.py | 86 ++++++++-------
.../pyflink/fn_execution/operation_utils.py | 6 +
.../pyflink/proto/flink-fn-execution.proto | 1 +
.../DataStreamPythonReduceFunctionOperator.java | 122 +++++++++++++++++++++
.../DataStreamPythonStatelessFunctionOperator.java | 18 +--
8 files changed, 309 insertions(+), 64 deletions(-)
create mode 100644
flink-python/src/main/java/org/apache/flink/datastream/runtime/operators/python/DataStreamPythonReduceFunctionOperator.java
