This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 1dee35a9966 [FLINK-28624][csv] Accept mapper/schema factories
new 1b8e776a915 [FLINK-28644][datastream] Add DataStream#collectAsync
new d788f0a2af3 [FLINK-28644][tests] Migrate state-processing-api to new
collectAsync()
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
docs/content.zh/docs/dev/datastream/overview.md | 9 +-
docs/content/docs/dev/datastream/overview.md | 9 +-
.../flink/state/api/SavepointWriterITCase.java | 52 +++-----
.../state/api/SavepointWriterWindowITCase.java | 82 +++++-------
.../flink/state/api/WritableSavepointITCase.java | 50 +++----
.../state/api/WritableSavepointWindowITCase.java | 86 ++++++------
...st_stream_execution_environment_completeness.py | 3 +-
.../flink/streaming/api/datastream/DataStream.java | 84 +++++++++++-
.../environment/StreamExecutionEnvironment.java | 10 ++
.../flink/streaming/api/scala/DataStream.scala | 38 +++++-
.../scala/StreamingScalaAPICompletenessTest.scala | 2 +
.../flink/streaming/util/StreamCollector.java | 146 ---------------------
.../streaming/util/StreamCollectorExtension.java | 146 ---------------------
.../datastream/DataStreamCollectTestITCase.java | 73 +++++++++++
14 files changed, 313 insertions(+), 477 deletions(-)
delete mode 100644
flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/streaming/util/StreamCollector.java
delete mode 100644
flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/streaming/util/StreamCollectorExtension.java
