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

Posted to commits@flink.apache.org by di...@apache.org on 2021/08/02 09:52:07 UTC

[flink] branch master updated (c8644c8 -> acaa5a8)

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 c8644c8  [FLINK-23518][tests] Wait until curator has connected
     add acaa5a8  [FLINK-23578][python] Remove PythonFlatMapOperator/PythonMapOperator/PythonPartitionCustomOperator operators

No new revisions were added by this update.

Summary of changes:
 flink-python/pyflink/datastream/data_stream.py     | 511 ++++++++++++---------
 flink-python/pyflink/datastream/functions.py       | 115 -----
 .../pyflink/datastream/tests/test_data_stream.py   |  26 +-
 .../pyflink/fn_execution/datastream/operations.py  |   8 +-
 .../pyflink/fn_execution/flink_fn_execution_pb2.py |  56 +--
 .../pyflink/proto/flink-fn-execution.proto         |  16 +-
 .../apache/flink/python/util/PythonConfigUtil.java |   8 +-
 .../python/PartitionCustomKeySelector.java         |   6 +-
 .../operators/python/PythonFlatMapOperator.java    |  77 ----
 .../api/operators/python/PythonMapOperator.java    |  54 ---
 .../python/PythonPartitionCustomOperator.java      |  75 ---
 .../operators/python/PythonProcessOperator.java    |  23 +
 12 files changed, 376 insertions(+), 599 deletions(-)
 delete mode 100644 flink-python/src/main/java/org/apache/flink/streaming/api/operators/python/PythonFlatMapOperator.java
 delete mode 100644 flink-python/src/main/java/org/apache/flink/streaming/api/operators/python/PythonMapOperator.java
 delete mode 100644 flink-python/src/main/java/org/apache/flink/streaming/api/operators/python/PythonPartitionCustomOperator.java