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/18 01:34:20 UTC

[flink] branch master updated (917c3d2 -> 3c61dac)

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 917c3d2  [FLINK-18947][python] Support partition_custom() for Python DataStream API. (#13155)
     add 3c61dac  [FLINK-18886][python] Support Kafka connectors for Python DataStream API. (#13161)

No new revisions were added by this update.

Summary of changes:
 flink-python/pyflink/datastream/connectors.py      | 489 +++++++++++++++++++++
 .../pyflink/datastream/tests/test_connectors.py    | 102 +++++
 flink-python/pyflink/pyflink_gateway_server.py     |   3 -
 .../pyflink/table/tests/test_descriptor.py         |  34 +-
 flink-python/pyflink/testing/test_case_utils.py    |  26 +-
 5 files changed, 649 insertions(+), 5 deletions(-)
 create mode 100644 flink-python/pyflink/datastream/connectors.py
 create mode 100644 flink-python/pyflink/datastream/tests/test_connectors.py