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 cd02aff [FLINK-21387][tests] Remove test timeout from
DispatcherTest.testNonBlockingJobSubmission and
.testInvalidCallDuringInitialization
add 9404d464 [FLINK-21939][python] Support batch mode in Python DataStream
API for process operation and reduce operation
add 465393b [hotfix][python] Rename the parameter from result_type to
output_type for flat_map
add 186a086 [hotfix][python] Rename the parameter from key_type_info to
key_type for key_by
No new revisions were added by this update.
Summary of changes:
.../docs/dev/datastream/operators/overview.md | 6 +-
.../docs/dev/python/datastream/data_types.md | 2 +-
.../docs/dev/datastream/operators/overview.md | 8 +-
.../docs/dev/python/datastream/data_types.md | 2 +-
.../python/datastream/data_stream_job.py | 2 +-
flink-python/pyflink/datastream/data_stream.py | 120 ++++++++---
flink-python/pyflink/datastream/functions.py | 6 +-
.../pyflink/datastream/tests/test_data_stream.py | 232 ++++++++++++---------
.../tests/test_stream_execution_environment.py | 2 +-
.../pyflink/fn_execution/flink_fn_execution_pb2.py | 141 +++++++------
flink-python/pyflink/fn_execution/operations.py | 10 +-
.../pyflink/proto/flink-fn-execution.proto | 1 +
.../python/AbstractPythonFunctionOperator.java | 49 +++++
.../python/OneInputPythonFunctionOperator.java | 6 +-
.../python/PythonKeyedCoProcessOperator.java | 9 +-
.../python/PythonKeyedProcessOperator.java | 23 +-
.../python/TwoInputPythonFunctionOperator.java | 6 +-
.../python/beam/BeamPythonFunctionRunner.java | 11 +-
.../streaming/api/utils/PythonOperatorUtils.java | 26 ++-
.../state/BatchExecutionKeyedStateBackend.java | 2 +-
20 files changed, 424 insertions(+), 240 deletions(-)
