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:56:28 UTC

[flink] branch master updated (fa9e4a5 -> 0dad895)

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 fa9e4a5  [FLINK-18864][python] Support key_by() operation for Python DataStream API. (#13097)
     add 0dad895  [FLINK-18861][python] Support add_source() for Python DataStream API. (#13095)

No new revisions were added by this update.

Summary of changes:
 flink-python/pom.xml                               |  1 +
 flink-python/pyflink/datastream/functions.py       | 14 +++++++++++
 .../datastream/stream_execution_environment.py     | 18 +++++++++++++++
 .../tests/test_stream_execution_environment.py     | 13 +++++++++++
 .../flink/python/util/MyCustomSourceFunction.java  | 27 ++++++++++++----------
 5 files changed, 61 insertions(+), 12 deletions(-)
 copy flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraRowOutputFormat.java => flink-python/src/test/java/org/apache/flink/python/util/MyCustomSourceFunction.java (59%)