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/05 07:51:48 UTC

[flink] branch master updated (94b2388 -> c966182)

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 94b2388  [FLINK-18769][table-planner-blink] Fix MiniBatch doesn't work with FLIP-95 source (#13038)
     add c966182  [FLINK-18764][python] Add DataStream class and support from_collection() in StreamExecutionEnvironment. (#13061)

No new revisions were added by this update.

Summary of changes:
 flink-python/pom.xml                               |  14 ++
 flink-python/pyflink/datastream/data_stream.py     | 162 +++++++++++++++++++++
 .../datastream/stream_execution_environment.py     |  62 +++++++-
 .../pyflink/datastream/tests/test_data_stream.py   |  61 ++++++++
 .../tests/test_stream_execution_environment.py     |  30 ++++
 flink-python/pyflink/datastream/tests/test_util.py |  56 +++++++
 flink-python/pyflink/pyflink_gateway_server.py     |   1 +
 .../flink/api/common/python/PythonBridgeUtils.java |   2 +-
 .../python/util/DataStreamTestCollectSink.java     |  56 +++++++
 .../planner/utils/python/PythonTableUtils.scala    |  52 ++++++-
 10 files changed, 493 insertions(+), 3 deletions(-)
 create mode 100644 flink-python/pyflink/datastream/data_stream.py
 create mode 100644 flink-python/pyflink/datastream/tests/test_data_stream.py
 create mode 100644 flink-python/pyflink/datastream/tests/test_util.py
 create mode 100644 flink-python/src/test/java/org/apache/flink/python/util/DataStreamTestCollectSink.java