You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by he...@apache.org on 2020/08/11 01:44:41 UTC

[flink] branch master updated (a5a0058 -> fa9e4a5)

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 a5a0058  [FLINK-18798][docs-zh] Translate "Debugging Windows & Event Time" page of "Debugging & Monitoring" into Chinese
     add fa9e4a5  [FLINK-18864][python] Support key_by() operation for Python DataStream API. (#13097)

No new revisions were added by this update.

Summary of changes:
 flink-python/pyflink/datastream/data_stream.py     | 97 +++++++++++++++++++++-
 flink-python/pyflink/datastream/functions.py       | 43 ++++++++++
 .../pyflink/datastream/tests/test_data_stream.py   | 35 ++++++++
 flink-python/pyflink/datastream/tests/test_util.py |  5 ++
 .../functions/python/PickledKeySelector.java       | 39 +++++----
 5 files changed, 202 insertions(+), 17 deletions(-)
 copy flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamMap.java => flink-python/src/main/java/org/apache/flink/datastream/runtime/functions/python/PickledKeySelector.java (50%)