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 a4ccc6e [FLINK-21104][network] Priority notification after
cancellation.
add 3796e59 [FLINK-21112][python] Add ValueState/ListState/MapState and
corresponding StateDescriptors for Python DataStream API.
No new revisions were added by this update.
Summary of changes:
flink-python/pyflink/common/state.py | 130 +++++++++++++++++++--
flink-python/pyflink/datastream/functions.py | 37 +++++-
.../pyflink/datastream/tests/test_data_stream.py | 91 ++++++++++++++-
flink-python/pyflink/fn_execution/operations.py | 48 +++++++-
.../python/beam/BeamPythonFunctionRunner.java | 10 +-
5 files changed, 298 insertions(+), 18 deletions(-)
